RxJs Packages

Official Rxstore Observer bindings for React Router

A lightweight library for creating Plex connections over WebSocket, enabling multiplexed communication for real-time applications.

A reactive peer-to-peer management library built on RxJS and Protoplex for efficient signaling, matchmaking, and multiplexing.

A ping-pong mechanism using rxprotoplex and RxJS for managing reliable connections.

A library for managing RPC connections using RxJS and Protoplex.

Reactive state management written in TypeScript with a minimal API and full power of RxJS

The minimal RxJs: the observable only

When RxJS meets async/await

Provides the concatJoin RxJS operator, used to simplify lists of sequential requests with accumulation of the results

RxJS ReplaySubjects with with additional features to make reactive programming easier

Global cache service for responses fetched by RxJS observables

**With npm:**

Eliminates manual state management for loading and error states by transforming Observables into a LoadingState

An RxJS operator for logging Observable lifecycle events with custom styling

An RxJS map operator that takes an observable of arrays as input and emits arrays where each element represents emissions from the projected observable.

rxjs for wechat miniprogram.

A number of Typescript Sets that publish changes in their state (entries added, created, updated or deleted) using RxJS Observables.

A no fuss rxjs wrapper for kafkajs, focused on ease of use.

rxjs + kafkajs

ETL extension for RxJs library