@reactive-js/observable-resource NPM

@reactive-js/observable-resource

Utilities for creating, composing and transforming reactive-js Observable resources, eg Observable streams with lifecyle semantics, such as Subjects.

Installation

via npm

npm install @reactive-js/observable-resource

via yarn

yarn add @reactive-js/observable-resource

Usage

import { subscribe, createSubject } from "@reactive-js/rx";
import {
  exhaust,
  generate,
  map,
  onNext,
} from "@reactive-js/observable-resource";
import { pipe } from "@reactive-js/pipe";
import { createSchedulerWithPriority } from "@reactive-js/node";

const scheduler = createSchedulerWithPriority(500);
const subject = createSubject();

// Create a stateful observable resource which shares the subjects
// underly disposable. eg. disposing observableResource disposes
// subject as well.
const subscription = pipe(
  subject,
  map(x => fromArray([x, x, x, x])),
  exhaust(),
  onNext(console.log),
  subscribe(scheduler);
);