AsyncTransformer.distinctPrevious | /stream/async/async-transformer.ts | rimbu@1.0.3

function AsyncTransformer.distinctPrevious

import { AsyncTransformer } from "https://deno.land/x/rimbu@1.0.3/stream/async/async-transformer.ts";
const { distinctPrevious } = AsyncTransformer;

distinctPrevious<T>(eq?: Eq<T>): AsyncTransformer<T>

Returns an async transformer that returns only those elements from the input that are different to previous element according to the optionally given eq function.

Examples

Example 1

await AsyncStream.of(1, 1, 2, 3, 2, 2)
  .transform(AsyncTransformer.distinctPrevious())
  .toArray()
// => [1, 2, 3, 2]

Type Parameters

Parameters

optional

eq: Eq<T> = [UNSUPPORTED]

(default: Eq.objectIs) the equality testing function

Returns

AsyncTransformer<T>