Searched refs:event_obj (Results 1 – 1 of 1) sorted by relevance
83 event_obj = self._rpc_client.eventWait(50000)92 if not event_obj:94 elif 'name' not in event_obj:95 self.log.error('Received Malformed event {}'.format(event_obj))98 event_name = event_obj['name']106 self.handle_subscribed_event(event_obj, event_name)110 self._event_dict[event_name].put(event_obj)113 q.put(event_obj)343 def handle_subscribed_event(self, event_obj, event_name): argument354 self._executor.submit(handler, event_obj, *args)