AsyncTransformer.distinctPrevious | /mod.ts | rimbu@1.1.0

x/rimbu/mod.ts>AsyncTransformer.distinctPrevious

Rimbu is a TypeScript library focused on immutable, performant, and type-safe collections and other tools.

actor base bimap bimultimap channel collection-types common core deep graph hashed list multimap multiset ordered proximity reactor sorted spy stream table typical

mod.ts (default module)

ArrowValuedGraphHashed

ArrowValuedGraphSorted

EdgeValuedGraphHashed

EdgeValuedGraphSorted

HashMultiMapHashValue

HashMultiMapSortedValue

HashMultiSet

HashSet

HashTableHashColumn

HashTableSortedColumn

SortedMultiMapHashValue

SortedMultiMapSortedValue

SortedMultiSet

SortedSet

SortedTableHashColumn

SortedTableSortedColumn

function AsyncTransformer.distinctPrevious

import { AsyncTransformer } from "https://deno.land/x/rimbu@1.1.0/mod.ts";
const { distinctPrevious } = AsyncTransformer;

distinctPrevious<T>(options?: { eq?: Eq<T>; negate?: boolean; }): 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

options: { eq?: Eq<T>; negate?: boolean; } = [UNSUPPORTED]

(optional) object specifying the following properties
eq: (default: Eq.objectIs) the Eq instance to use to test equality of elements
negate: (default: false) when true will negate the given predicate

Returns

AsyncTransformer<T>