ConnectableStreamSubscription<T> constructor Null safety

ConnectableStreamSubscription<T>(
  1. StreamSubscription<T> _source,
  2. Subject<T> _subject
)

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

Implementation

ConnectableStreamSubscription(this._source, this._subject);