method Stream.partition
Stream.partition<S>(source: Source<S>): Task<
{ values: Exclude<S, AnyFailure>[]; errors: Extract<S, AnyFailure>[]; },
never
>

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

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

Type Parameters

Parameters

source: Source<S>

Return Type

Task<
{ values: Exclude<S, AnyFailure>[]; errors: Extract<S, AnyFailure>[]; },
never
>

Usage

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