method StreamClass.dedup
Private
StreamClass.dedup<S>(source: Source<S>): StreamClass<Exclude<S, AnyFailure>, Extract<S, AnyFailure>>

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

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

Type Parameters

Parameters

source: Source<S>

Return Type

StreamClass<Exclude<S, AnyFailure>, Extract<S, AnyFailure>>

Usage

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