subscribe method
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();
});
}