OnErrorResumeStreamTransformer<S> 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.

Example

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

Inheritance

• Object
• StreamTransformerBase<S, S>
• OnErrorResumeStreamTransformer

Constructors

OnErrorResumeStreamTransformer(Stream<S> recoveryFn(Object error, StackTrace stackTrace))

Constructs a StreamTransformer which intercepts error events and switches to a recovery Stream created by the provided recoveryFn Function.

Properties

hashCode → int

The hash code for this object.

no setter, inherited

recoveryFn → Stream<S> Function(Object error, StackTrace stackTrace)

Method which returns a Stream, based from the error.

final

runtimeType → Type

A representation of the runtime type of the object.

no setter, inherited

Methods

bind(Stream<S> stream) → Stream<S>

Transforms the provided stream.

override

cast<RS, RT>() → StreamTransformer<RS, RT>

Provides a StreamTransformer<RS, RT> view of this stream transformer.

inherited

noSuchMethod(Invocation invocation) → dynamic

Invoked when a nonexistent method or property is accessed.

inherited

toString() → String

A string representation of this object.

inherited

Operators

operator ==(Object other) → bool

The equality operator.

inherited