autoConnect method

  1. @override
ValueStream<T> autoConnect (
  1. {void connection(
    1. StreamSubscription<T> subscription
    )}
)
override

Returns a Stream that automatically connects (at most once) to this ConnectableStream when the first Observer subscribes.

To disconnect from the source Stream, provide a connection callback and cancel the subscription at the appropriate time.

Implementation

@override
ValueStream<T> autoConnect({
  void Function(StreamSubscription<T> subscription) connection,
}) {
  _subject.onListen = () {
    if (connection != null) {
      connection(connect());
    } else {
      connect();
    }
  };

  return _subject;
}