execute method

Future<void> execute(
  1. Stream<T> src
)

Execute the stream

Implementation

Future<void> execute(Stream<T> src) async {
  if (_done || _fetching) return;
  _fetching = true;
  _subscription = src.listen(
    setValue,
    onError: setError,
    onDone: _finish,
    cancelOnError: cancelOnError,
  );
}