JSPM

Found 63 results for backpressure

memoz

Memoz is an in-memory database that persists on disk. The data model is key-value.

  • v4.2.0
  • 65.28
  • Published

ts-stream

Type-safe object streams with seamless support for backpressure, ending, and error handling

  • v3.0.0
  • 59.39
  • Published

web-streams-extensions

A comprehensive collection of helper methods for WebStreams with built-in backpressure support, inspired by ReactiveExtensions

  • v1.1.0
  • 55.84
  • Published

bpmux

Node stream multiplexing with back-pressure on each stream

  • v8.2.1
  • 52.15
  • Published

@mixmaxhq/promise-pool

Concurrent control of functions on a per-pool basis with async/await

  • v3.0.0
  • 47.65
  • Published

sinek

Node.js kafka client, consumer, producer polite out of the box

  • v10.0.0-alpha.0
  • 46.65
  • Published

@push.rocks/smartstream

A library to simplify the creation and manipulation of Node.js streams, providing utilities for handling transform, duplex, and readable/writable streams effectively in TypeScript.

  • v3.2.5
  • 45.55
  • Published

@flowfuse/nr-tables-nodes

Nodes for use with the FlowFuse Tables offering, allowing developers to write and run queries against databases inside FlowFuse Tables.

  • v0.1.0
  • 42.69
  • Published

@push.rocks/smartrx

A smart wrapper for rxjs to manage and extend observables.

  • v3.0.10
  • 41.49
  • Published

node-red-contrib-ui-upload

Node-RED Dashboard UI widget node for uploading a file content by Socket.io streaming

  • v0.8.1
  • 39.40
  • Published

caminho

Tool for creating efficient data pipelines in a JavaScript environment

  • v1.7.4
  • 36.47
  • Published

zero-backpressure-semaphore-typescript

A modern Promise-semaphore for Node.js projects, enabling users to limit the number of concurrently executing promises. Offering backpressure control for enhanced efficiency, utilizing a communicative API that signals availability, promoting a just-in-tim

  • v3.1.3
  • 34.84
  • Published

zero-overhead-promise-lock

An efficient Promise lock for Node.js projects, ensuring mutually exclusive execution of asynchronous tasks. Key features include a backpressure indicator, access to the currently executing task promise for smart reuse (useful when launching a duplicate t

  • v1.2.1
  • 34.43
  • Published

fluxforge

Enterprise-grade file chunking & concurrent processing library with Web Workers, automatic retry, real-time progress tracking, and MD5 integrity validation for modern browsers. Perfect for large file uploads, streaming, and data processing pipelines.

  • v0.0.3
  • 32.01
  • Published

throttlers

[![Version](https://img.shields.io/npm/v/throttlers.svg)](https://www.npmjs.com/package/throttlers) [![Maintenance](https://img.shields.io/maintenance/yes/2025)](https://github.com/havelessbemore/throttlers/graphs/commit-activity) [![License](https://img.

  • v0.1.0
  • 27.94
  • Published

hystrix-too-busy

Provides a backpressure management hystrix command partially based on too-busy module logic and utilizing hystrix metrics accumulation and circuit breaking

  • v0.2.0
  • 25.51
  • Published

ws-streamify

Pipe Node.js streams over WebSockets (with back-pressure!).

  • v0.1.4
  • 25.50
  • Published

aono

asynchronous logger for node with back-pressure capability

  • v2.5.0
  • 23.51
  • Published

zero-backpressure-weighted-promise-semaphore

A modern weighted promise semaphore for Node.js projects, ideal for managing workloads with varying processing requirements. It allows limiting the total weight of concurrently executing jobs, ensuring efficient resource utilization. Offering backpressure

  • v1.0.15
  • 22.20
  • Published

drain-aware-transform

Simple wrapper to allow backpressure-aware Transform streams

  • v1.0.1
  • 21.31
  • Published

corsa

Async iteration channels in JavaScript.

  • v1.0.2
  • 20.00
  • Published

eloy-ui-upload

Custom dashboard node for Eloy

    • v0.0.4
    • 17.70
    • Published

    rx-reader

    Fast async lossless back-pressure streaming library based on RxJS and generators.

    • v1.0.0-rc.2
    • 15.10
    • Published

    reactor-core-ts

    The Reactive-Streams based implementation of Reactor-Core

    • v1.0.8-beta
    • 14.91
    • Published

    redisclient

    a lightweight wrapper around mrraney's redis lib to make it easier to adapt to backpressure

    • v0.0.8
    • 14.80
    • Published

    stream-viz

    Visualizes a stream in the browser.

    • v0.0.7
    • 13.34
    • Published

    zero-backpressure-fixed-window-promise-rate-limiter

    A modern Promise rate-limiter for Node.js projects, implementing a fixed-window throttling policy. It restricts the number of tasks that can *start* execution within distinct, non-overlapping time windows. The API provides backpressure control by signalin

    • v1.0.6
    • 13.17
    • Published

    @lyleunderwood/streaming-zipper

    Memory-efficient streaming ZIP creation with automatic backpressure control. Supports parallel reading + sequential writing for both Web Streams and Node.js streams with ZIP64 support.

    • v1.0.2
    • 11.37
    • Published

    trooba-toobusy-handler

    Trooba based handler that provides more consistent too busy functionality based on hystrixjs and toobusy-js functionality

    • v1.0.0
    • 11.14
    • Published

    teth-pipe

    Minimal, functional, monadic, promise-compatible streaming framework with backpressure.

    • v1.0.9
    • 7.62
    • Published

    bayeuxjs

    Simple pub/sub messaging for the web with backpressure

    • v1.0.4
    • 7.18
    • Published

    nano-redis

    Redis Adapter for nanoSQL https://nanosql.io

    • v1.7.2
    • 6.92
    • Published

    redis-knack

    Redis client library

    • v2.5.1
    • 6.26
    • Published

    hybrid-cache

    hybrid-cache is a cache uses memory-cache and Redis

    • v1.0.30
    • 4.59
    • Published

    rxlax

    Make Rx.js to relax a bit

    • v1.1.0
    • 4.40
    • Published

    sinthic

    Type-safe object streams with seamless support for backpressure, ending, and error handling

    • v1.5.0
    • 2.77
    • Published

    influx-kapacitor

    An influx broadcaster supporting multiple transmission protocols and applies backpressure to reduce chattiness.

    • v0.8.7
    • 2.72
    • Published

    niugu-redis

    Redis client library

    • v2.6.5
    • 2.62
    • Published

    ts-backpressure

    Utility class to apply backpressure to the function invocations

    • v0.1.0
    • 2.57
    • Published

    super-loop

    Producer-consumer implementation based on nodejs stream

    • v0.3.1
    • 2.57
    • Published

    stream-fs-cache

    A node duplex stream used for caching stream information to the file system while processing. This module is very helpful when large amounts of data need to be processed over the network, while ensuring that the connection is not open for a long period o

    • v1.0.4
    • 0.00
    • Published

    safe-batch-stream

    Safely creates an array of elements inside a stream. It prevents [backpressuring in streams](https://nodejs.org/es/docs/guides/backpressuring-in-streams/) by waiting the drain after reaching a limit of batches built

    • v1.0.2
    • 0.00
    • Published

    priority-scheduler-queue

    [![npm version](https://img.shields.io/npm/v/priority-scheduler-queue.svg)](https://www.npmjs.com/package/priority-scheduler-queue) ![node](https://img.shields.io/badge/node-%3E%3D18-brightgreen) ![types](https://img.shields.io/badge/types-TypeScript-bl

      • v0.1.0
      • 0.00
      • Published

      redisv3

      A high performance Redis client.(by wush 2023-09-10, for use v3 both and v4)

      • v3.1.2
      • 0.00
      • Published

      @tekim/ts-stream

      Type-safe object streams with seamless support for backpressure, ending, and error handling

      • v2.1.0
      • 0.00
      • Published

      xredis

      A high performance Node.js Redis client with redis ACL functionalities

      • v1.0.4
      • 0.00
      • Published

      backpressurify

      Wrapper for `Duplex` stream objects to ensure they respect back-pressure

      • v0.0.0
      • 0.00
      • Published