listenOn<T> method

StreamSubscription<T> listenOn<T>(
  1. void onData(
    1. T
    ), {
  2. Function? onError,
  3. void onDone()?,
  4. bool? cancelOnError,
  5. Object? key,
})
override

Implementation

StreamSubscription<T> listenOn<T>(void Function(T) onData,
    {Function? onError,
    void Function()? onDone,
    bool? cancelOnError,
    Object? key}) {
  final subscription =
      streamOf<T>(key: key).listen(onData, onError: onError, onDone: onDone);
  //adding on subcription, to clean on future.
  _loadedSubscription.add(subscription);

  return subscription;
}