@push-stream-std/push-partition (0.0.8)

Published 2026-07-20 21:38:23 +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-partition@0.0.8

or add it to the package.json file:

"@push-stream-std/push-partition": "0.0.8"

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

@push-stream-std/push-partition

Split a stream into two branches based on a predicate — one for truthy, one for falsy.

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

Synopsis

import partition from '@push-stream-std/push-partition';
import pushable from '@push-stream-std/push-pushable';
import concat from '@push-stream-std/push-concat';

const source = pushable();

const [evens, odds] = partition(function isEven(x) {
  return x % 2 === 0;
}, source);

evens.pipe(concat((err, result) => {
  console.log('evens:', result); // [2, 4]
}));

odds.pipe(concat((err, result) => {
  console.log('odds:', result); // [1, 3, 5]
}));

source.push(1);
source.push(2);
source.push(3);
source.push(4);
source.push(5);
source.end();

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-partition

Why

A stream splitter that routes values through a predicate function into two output source streams. Values where predicate(value) returns truthy go to the first branch; falsy values go to the second. Each branch supports independent piping, resuming, and aborting. If the predicate throws, both branches end with that error.

API

`partition(predicate, source)`

Splits a source stream into two branches.

predicate (value) => boolean – Determines which branch receives each value.
source source stream – The input source to partition.
Returns [trueBranch, falseBranch] – Two source streams. Each supports pipe(), resume(), and abort(). Both receive end() and abort() signals from the source.

Tests

npm test

Tests cover routing values to correct branch, independent branch piping, end propagation to both branches, abort handling, and predicate errors.

Requirements

Node.js 22 or later. ESM only.

Dependencies

ID	Version
@push-stream-std/push-stream-base	*

push-stream stream partition split filter

Details

npm

2026-07-20 21:38:23 +00:00

SEE LICENSE IN LICENSE

3.8 KiB

Assets (1)

push-partition-0.0.8.tgz 3.8 KiB

Versions (6) View all

0.0.9

2026-07-21

0.0.8

2026-07-20

0.0.7

2026-07-20

0.0.6

2026-07-19

0.0.5

2026-07-19

@push-stream-std/push-partition (0.0.8)

Installation

About this package