RetryWhenStream<T> constructor

RetryWhenStream<T>(
  1. Stream<T> streamFactory(),
  2. Stream<void> retryWhenFactory(
    1. Object error,
    2. StackTrace stackTrace
    )
)

Constructs a Stream that will recreate and re-listen to the source Stream (created by the provided factory method). The retry will trigger whenever the Stream created by the retryWhen factory emits and event.

Implementation

RetryWhenStream(this.streamFactory, this.retryWhenFactory);