subscribe<T> method
subscribe for interactors
Implementation
StreamSubscription<T> subscribe<T>(
Stream<T> stream,
void Function(T value) onValue, {
void Function(Object error)? onError,
}) =>
_compositeSubscription
.add<T>(stream.listen(onValue, onError: onError?.call));