Arbor RXJS Binding

RXJS binding for @arborjs/store.

[!WARNING] This is currently an experimental project, use it at your own risk in production.

Installation

Via npm

1npm install @arborjs/rxjs

Or via yarn

1yarn add @arborjs/rxjs

Make sure you have @arborjs/store installed.

Usage

1import { Arbor } from "@arborjs/store"
2import { from } from "@arborjs/rxjs"
3import { filter } from "rxjs/operators"
4
5const store = new Arbor({
6  count: 0
7})
8
9// 1. Create an Observable version of the store
10const observable = from(store)
11
12// 2. Use RXJS APIs to process a stream of mutation events triggered by the store
13observable
14  .pipe(filter((event) => event.state.count % 2 === 0))
15  .forEach((event) => {
16    console.log("Even count:", event.state.count)
17  })
18  .catch(console.error)
19
20store.state.count++
21store.state.count++
22=> Even count: 2
23store.state.count++
24store.state.count++
25=> Even count: 4