def pump_reader(self):
origin, message = self.transport.read_packet()<EOL>if isinstance(origin, MessageTargetWatch):<EOL><INDENT>self._handle_watch_message(message)<EOL><DEDENT>else:<EOL><INDENT>self._broadcast_transport_message(origin, message)<EOL><DEDENT>
Synchronously reads one message from the watch, blocking until a message is available.
All events caused by the message read will be processed before this method returns.

.. note::
   You usually don't need to invoke this method manually; instead, see :meth:`run_sync` and :meth:`run_async`.