method StreamClass.prototype.results
Private
StreamClass.prototype.results(): Task<Result<T, E>[], never>

Collects every element, positionally, failures included — the Task.results of streams. Each failure is reported to the observation seam as it is classified into the value world, so tracing sees per-element failures a consumer chose to keep.

import * as Failure from '../result/failure.ts';

const Odd = Failure.define('Odd', (d: { n: number }) => `${d.n} is odd`);
const outcomes = await Stream.from([2, Odd({ n: 3 }), 4]).results();
outcomes.length; // 3 — nothing lost, order kept

Return Type

Task<Result<T, E>[], never>

Usage

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