Subjects

Subject

Value

class broqer.Value(init=<class 'broqer.types.NONE'>)

Value is a publisher and subscriber.

>>> from broqer import Sink

>>> s = Value(0)
>>> _d = s.subscribe(Sink(print))
0
>>> s.emit(1)
1