method StreamClass.cycle
Private
StreamClass.cycle<U>(source: Source<U>): StreamClass<Exclude<U, AnyFailure>, Extract<U, AnyFailure>>

Repeats a re-iterable source forever — always bound it (take, takeWhile).

await Stream.cycle([1, 2]).take(5).collect(); // [1, 2, 1, 2, 1]

Type Parameters

Parameters

source: Source<U>

Return Type

StreamClass<Exclude<U, AnyFailure>, Extract<U, AnyFailure>>

Usage

import { StreamClass } from "lib/stream/stream.ts";