StreamClass.repeatedly<U>(fn: () => U | PromiseLike<U>): StreamClass<U>
Calls fn for each pull, forever — Elixir's Stream.repeatedly/1.
let n = 0; await Stream.repeatedly(() => ++n).take(3).collect(); // [1, 2, 3]
Usage
import { StreamClass } from "lib/stream/stream.ts";