most-observable
v0.0.2
Published
Create @most/core compatible streams from observables
Downloads
2
Readme
most-observable
Create @most/core
streams from ES observables.
Install
yarn add most-observable
npm i -s most-observable
Example
Creating state stream from redux store as it is an Observable but any ES observable should work.
import fromObservable from "most-observable";
import { runEffects, tap } from "@most/core";
import { newDefaultScheduler } from "@most/scheduler";
const store = createStore(reducer); // Redux store
const state$ = fromObservable(store);
runEffects(tap(console.log, state$), newDefaultScheduler());
API
- fromObservable
const stream = fromObservable(observable);