You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Suggestion, may want to mention: StreamController onListen side effect triggering logic is different than Observable onSubscribe (for create operator).
Well, Observable onSubscribe is not officially documented in ReactiveX that it must be called every time Observable is subscribed, but it is in all existing rx implementations.
But for broadcast stream, the onListen is only be called at the first time it is subscribed, so that it is equal to observable.publish().autoConnect(1). (For non-broadcast stream, it is fine since it can not be subscribed multiple times)
This includes:
first
,last
, etc returnsFuture
not anObservable
The text was updated successfully, but these errors were encountered: