method StreamClass.collect
Private
StreamClass.collect<S>(source: Source<S>): Task<Exclude<S, AnyFailure>[], Extract<S, AnyFailure>>

StreamClass#collect as a static: Stream.collect(source, …) is Stream.from(source).collect(…).

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

Type Parameters

Parameters

source: Source<S>

Return Type

Task<Exclude<S, AnyFailure>[], Extract<S, AnyFailure>>

Usage

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