RetryStream<T> constructor

RetryStream<T>(
  1. Stream<T> streamFactory(), [
  2. int? count
])

Constructs a Stream that will recreate and re-listen to the source Stream (created by the provided factory method) the specified number of times until the Stream terminates successfully. If count is not specified, it retries indefinitely.

Implementation

RetryStream(this.streamFactory, [this.count]);