OnErrorResumeNextStreamTransformer<T> class

Deprecated: Please use OnErrorResumeStreamTransformer.

Intercepts error events and switches to the given recovery stream in that case

The OnErrorResumeNextStreamTransformer 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.

Example

new ErrorStream(new Exception())
  .transform(new OnErrorResumeNextStreamTransformer(
    new Observable.fromIterable([1, 2, 3])))
  .listen(print); // prints 1, 2, 3
Annotations
  • @deprecated

Constructors

OnErrorResumeNextStreamTransformer(Stream<T> recoveryStream)

Properties

transformer → StreamTransformer<T, T>
final
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

Methods

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.
inherited
noSuchMethod(Invocation invocation) → dynamic
Invoked when a non-existent method or property is accessed.
inherited
toString() → String
Returns a string representation of this object.
inherited

Operators

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