subscribeHandleError<T> method
subscribe for interactors with default handle error
Implementation
StreamSubscription<T> subscribeHandleError<T>(
Stream<T> stream,
void Function(T value) onValue, {
void Function(Object error)? onError,
}) {
// ignore: avoid_types_on_closure_parameters
final subscription = stream.listen(onValue, onError: (Object e) {
handleError(e);
onError?.call(e);
});
return _compositeSubscription.add<T>(subscription);
}