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);