MCPcopy Create free account
hub / github.com/apache/qpid-proton / trigger

Method trigger

python/proton/_reactor.py:426–435  ·  view source on GitHub ↗

Request that the given event be dispatched on the event thread of the container to which this EventInjector was added. :param event: Event to be injected :type event: :class:`proton.Event`, :class:`ApplicationEvent`

(self, event: 'ApplicationEvent')

Source from the content-addressed store, hash-verified

424 self._closed = False
425
426 def trigger(self, event: 'ApplicationEvent') -> None:
427 """
428 Request that the given event be dispatched on the event thread
429 of the container to which this EventInjector was added.
430
431 :param event: Event to be injected
432 :type event: :class:`proton.Event`, :class:`ApplicationEvent`
433 """
434 self.queue.put(event)
435 os.write(self.pipe[1], b"!")
436
437 def close(self) -> None:
438 """

Callers 6

_get_idMethod · 0.80
_loadMethod · 0.80
_processMethod · 0.80

Calls 2

putMethod · 0.45
writeMethod · 0.45