withLatestFrom implementation for flyd streams

Framework-agnostic reactive state engine built on a graph of typed nodes.

Persistence in memory

Persistence in the browser's IndexedDB

RxJS operator returning an array of the next available values of each parameter observable

Utility functions for rx-js written in Typescript.

Everything is streams.

Taro hooks for RxJS

A set of utilities for leveraging rxjs more heavily in angular 2

This Manager allows you to manage your reactive (Angular) component. You can register new Events by simply using: `rcm.registerListener('listenerName', (observable) => observable.pipe(...)`

Stream driven redux state manager

Filter out null and undefined values in an Observable

Powerful Reactive Framework based on EventEmitter, Signals, and Object Stream Operators