OnErrorResumeStreamTransformer<T> class

Intercepts error events and switches to a recovery stream created by the provided recoveryFn Function.

The OnErrorResumeStreamTransformer intercepts an onError notification from the source Stream. Instead of passing the error through to any listeners, it replaces it with another Stream of items created by the recoveryFn.

The recoveryFn receives the emitted error and returns a Stream. You can perform logic in the recoveryFn to return different Streams based on the type of error that was emitted.


new Observable<int>.error(new Exception())
  .onErrorResume((dynamic e) =>
      new Observable.just(e is StateError ? 1 : 0)
  .listen(print); // prints 0


OnErrorResumeStreamTransformer(Stream<T> recoveryFn(dynamic error))
Constructs a StreamTransformer which intercepts error events and switches to a recovery Stream created by the provided recoveryFn Function.


hashCode → int
The hash code for this object.
read-only, inherited
runtimeType → Type
A representation of the runtime type of the object.
read-only, inherited


bind(Stream<T> stream) → Stream<T>
Transforms the provided stream. [...]
cast<RS, RT>() → StreamTransformer<RS, RT>
Provides a StreamTransformer<RS, RT> view of this stream transformer.
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed.
toString() → String
Returns a string representation of this object.


operator ==(dynamic other) → bool
The equality operator.