subscribe method

Subscription subscribe(
  1. void onData(
    1. T event
    ), {
  2. Function? onError,
  3. void onDone()?,
  4. bool? cancelOnError,
})

Implementation

Subscription subscribe(void Function(T event) onData,
    {Function? onError, void Function()? onDone, bool? cancelOnError}) {
  notSubscribed = false;
  _observable.stream.listen(onData,
      onError: onError, onDone: onDone, cancelOnError: cancelOnError);
  return Subscription(() {
    _observable.close();

    // Create a new instance to avoid errors
    _observable = StreamController();
  });
}