Searched refs:_process_incoming (Results 1 – 5 of 5) sorted by relevance
183 def _process_incoming(self, incoming): member in NotificationServer203 def _process_incoming(self, incoming): member in BatchNotificationServer
64 def _process_incoming(self, incoming): member in OptsTestCase.test_defaults.MessageHandlingServerImpl
368 self._work_executor.submit(self._process_incoming, incoming)371 def _process_incoming(self, incoming): member in MessageHandlingServer
152 def _process_incoming(self, incoming): member in RPCServer
679 def _process_incoming(self, incoming): member in TestServerLocking.setUp.MessageHandlingServerImpl