subscribe<T> method

void subscribe<T>(
  1. Stream<T> stream,
  2. void onValue(
    1. T value
    ), {
  3. void onError(
    1. Object error
    )?,
  4. void onDone()?,
  5. bool? cancelOnError,
})

Implementation

void subscribe<T>(
  Stream<T> stream,
  void Function(T value) onValue, {
  void Function(Object error)? onError,
  void Function()? onDone,
  bool? cancelOnError,
}) {
  final subscription = stream.listen(
    onValue,
    onError: onError?.call,
    onDone: onDone,
    cancelOnError: cancelOnError,
  );
  _subs.add(subscription);
}