@push-stream-std/push-distinct (0.0.7)

Published 2026-07-21 03:58:03 +00:00 by Dvorak

Set up this registry in your project .npmrc file:

@push-stream-std:registry=https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/

To install the package using npm, run the following command:

npm install @push-stream-std/push-distinct@0.0.7

or add it to the package.json file:

"@push-stream-std/push-distinct": "0.0.7"

For more information on the npm registry, see the documentation.

@push-stream-std/push-distinct

Emit only distinct/unique values.

Published as @push-stream-std/push-distinct.

Synopsis

import { distinct } from '@push-stream-std/push-distinct';
import { values } from '@push-stream-std/push-pushable';
import { collect } from '@push-stream-std/push-concat';

const source = values([1, 2, 2, 3, 3, 3, 1]);
const unique = distinct();

collect(source.pipe(unique), (err, result) => {
  console.log(result); // [1, 2, 3]
});

Install

npm config set @push-stream-std:registry https://hub.kl1.tenere.ai/api/packages/push-stream-std/npm/
npm config set -- //hub.kl1.tenere.ai/api/packages/push-stream-std/npm/:_authToken "$PACKAGE_TOKEN"
npm install @push-stream-std/push-distinct

Why

A through stream that filters out duplicate values using a Set. Each unique key is emitted only once. Supports custom key extraction for deduplication by object property, and a custom comparison function. Ideal for deduplication, preventing redundant operations, and ensuring each entity is processed once.

API

`distinct(keyOrOptions)`

Returns a through stream that emits only distinct values.

keyOrOptions function | object (optional)
- If a function: used as key extractor (data) => key for deduplication.
- If an object:
  - key (data) => any — Key extraction function. Values producing the same key are considered duplicates.
  - compare (a, b) => boolean — Custom equality comparison (not used by this implementation).
Returns through — A push-stream through that drops values whose key has already been seen.

Tests

npm test

Tests cover primitive deduplication, key-based deduplication, passthrough of non-duplicate values, and abort/end propagation.

Requirements

Node.js 22 or later. ESM only.

push-stream stream distinct deduplicate

Details

npm

2026-07-21 03:58:03 +00:00

0

SEE LICENSE IN LICENSE

latest

3.5 KiB

Assets (1)

push-distinct-0.0.7.tgz 3.5 KiB

Versions (5) View all

0.0.7

2026-07-21

0.0.6

2026-07-20

0.0.5

2026-07-20

0.0.4

2026-07-19

0.0.3