subscribeHandleError<T> method

StreamSubscription<T> subscribeHandleError<T>(
  1. Stream<T> stream,
  2. void onValue(
    1. T value
    ), {
  3. void onError(
    1. Object error
    )?,
})

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);
}