RepeatStream<T> constructor

RepeatStream<T>(Stream<T> streamFactory(int), [ int count ])

Constructs a Stream that will recreate and re-listen to the source Stream (created with the provided factory method). The count parameter specifies number of times the repeat will take place, until this Stream terminates successfully. If the count parameter is not specified, then this Stream will repeat indefinitely.


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