Producers

class Producer(ecore, logger=<RootLogger root (DEBUG)>)[source]

Bases: IProducer

Parameters:
produce(event, *, block=True, timeout=5)[source]

Produce an event

Parameters:
  • event (Event) – Event to produce

  • block (bool) – Should I/O be blocked if some delay occurs. Defaults to True.

  • timeout (int) – Number of seconds to wait in case of latency. Defaults to 5.

Returns:

None

Return type:

None