method StreamClass.run
Private
StreamClass.run<S>(source: Source<S>): Task<void, Extract<S, AnyFailure>>

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

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

Type Parameters

Parameters

source: Source<S>

Return Type

Task<void, Extract<S, AnyFailure>>

Usage

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