listenOn<T> method
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;
}