listen method

StreamSubscription<T> listen(
  1. void onData(
    1. T event
    )?, {
  2. Function? onError,
  3. void onDone()?,
  4. bool? cancelOnError,
})

Implementation

StreamSubscription<T> listen(void Function(T event)? onData,
    {Function? onError, void Function()? onDone, bool? cancelOnError}) {
  final sub = controller.stream.listen(onData,
      onError: onError, onDone: onDone, cancelOnError: cancelOnError);
  if (isRemoved) {
    listener.onListen(this);
    close();
  }

  return sub;
}