connect method

  1. @override
StreamSubscription<T> connect ()
override

Instructs the ConnectableObservable to begin emitting items from the source Stream. To disconnect from the source stream, cancel the subscription.

Implementation

@override
StreamSubscription<T> connect() {
  return ConnectableObservableStreamSubscription<T>(
    _source.listen(_subject.add, onError: _subject.addError),
    _subject,
  );
}