addStream method

Future<T?> addStream(
  1. Stream<T> source, {
  2. bool cancelOnError = true,
})

Implementation

Future<T?> addStream(Stream<T> source, {bool cancelOnError = true}) {
  return _subject.addStream(source, cancelOnError: cancelOnError)
      as Future<T?>;
}