redux-observable-action

A RxJS-based Redux middleware that flow out actions for easy side-effect processing

Inspired by redux-observable

Usage

1npm i redux-observable-action

1import { test, expect } from 'vitest'
2import { Action, applyMiddleware, legacy_createStore } from 'redux'
3import { Observable } from 'rxjs'
4import { createMiddleware } from 'redux-observable-action'
5
6const reducer = (state = 0, action) => {
7  switch (action.type) {
8    case 'INCREMENT':
9      return state + 1
10    case 'DECREMENT':
11      return state - 1
12    default:
13      return state
14  }
15}
16
17const streamerMiddleware = createMiddleware()
18const store = legacy_createStore(reducer, applyMiddleware(streamerMiddleware))
19
20function rootStreamer(action$: Observable<Action>) {
21  return action$.subscribe(action => {
22    if (action.type === 'INCREMENT') {
23      // do something
24    }
25  })
26}
27
28streamerMiddleware.run(rootStreamer)

More

• observable-duck: In-depth combination of redux use, complete types