Redux Observable Middleware - Cacher Snippet

9/30/2018 - 5:44 AM

Redux Observable Middleware

A basic example of the Redux-Observable middleware function.

reduxObservableMiddleware.js

const reduxObservableMiddleware = (
  store => {
    const reduxObservable$ = (
      new Subject()
    )
    
    reduxObservable$
    .subscribe(store.dispatch)

    return (
      action => {
        reduxObservable$
        .next(action)
        
        return (
          next => next()
        )
      }
    )
  }
)