bobocep.cep.engine.task.BoboEngineTask

class bobocep.cep.engine.task.BoboEngineTask[source]

Bases: abc.ABC

An engine task.

__init__()

abstract close() → None[source]: Closes the engine task.

abstract is_closed() → bool[source]

Returns: True if task is set to close; False otherwise.

abstract size() → int[source]

Returns: The number of events that the task is currently handling.

abstract update() → bool[source]

Returns: True if an update occurred in the task; False otherwise.