Hands-On Reactive Programming with Python

Operators – publish and connect

The publish operator converts an observable to a connectable observable. A connectable observable does not start to emit items when an observer subscribes to it, but when its connect method is called. The combination of publish and connect allows us to make an observable hot, but also to ensure that several observers will receive the whole sequence of items. The following figure shows its marble diagram:

Figure 4.14: The publish operator

The prototypes of the publish and connect operators are as follows:

Observable.publish(self)ConnectableObservable.connect(self)

Both of the operators are methods, but