bobocep.cep.engine.receiver.pubsub.BoboReceiverSubscriber

class bobocep.cep.engine.receiver.pubsub.BoboReceiverSubscriber[source]

Bases: abc.ABC

A receiver subscriber interface.

__init__()

abstract on_receiver_update(event: bobocep.cep.event.event.BoboEvent) → None[source]

Parameters: event – A new BoboEvent instance processed by the receiver.