ConnectableStreamSubscription<T> constructor

ConnectableStreamSubscription<T>(StreamSubscription<T> _source, Subject<T> _subject)

Constructs a special StreamSubscription, which will close the provided subject when cancel is called.

Implementation

ConnectableStreamSubscription(this._source, this._subject);