RXJS Packages

Another convenient flavor of Rx.Observable.combineLatest

Reactive Extensions - represents a deferred computation without any value but only indication for completion or exception.

Helper methods for assertions in unit tests for rxjs library

asyncFilter operator for RxJS

RxJS wrapper for the amqplib from squaremo

Computed observables (ala Knockout) for RxJS

Update BehavioralSubject on fulfilled conditions only

**Still under development.**

RxJS utilities for Electron JS

countdown timer library using RxJS Observables

rxjs typescript decorators

A DHT11 Sensor Driven written with Noejs. Monitoring temperature and humidity changes using RxJS.

Create DOM element and bind observables on it.

A Rx.Subject helper to manage intention in convenient way

RxJs wrapper for Node's fs module.

Observe any object's method calls

Make RxJS handle errors gracefully

represents a deferred computation and emission of a single value, no value at all or an exception.

A channeled messaging protocol implementation on top of TCP/TLS server and socket to enable rxjs messaging

rx-node-extra contains additional functionality not contained in the rx-node package, such as "ask" and "fromUnpausableStream".