Class Sub

distributed.pubsub.Sub

Subscribe to a Publish/Subscribe topic

Declaration

class Sub

Documentation

See also

Pub: for full docstring

Methods

▷ def __aiter__(self)
source link
▷ def __init__(self, name, worker=None, client=None)
source link
▷ def __iter__(self)
source link
▷ def __repr__(self)
source link
▷ def condition(self) @property
@property
def condition(self)
source link

▶ def get(self, timeout=None)

Get a single message

Parameters

timeout : number or string or timedelta

Time in seconds to wait before timing out.
Instead of number of seconds, it is also possible to specify
a timedelta in string format, e.g. "200ms".

Reexports

Imported in distributed.tests.test_pubsub.
Imported in distributed.