bobocep.dist.pubsub.BoboDistributedPublisher

class bobocep.dist.pubsub.BoboDistributedPublisher[source]

Bases: abc.ABC

A distributed publisher interface.

__init__()

abstract subscribe(subscriber: bobocep.dist.pubsub.BoboDistributedSubscriber) → None[source]

Parameters: subscriber – Subscriber to distributed.