kefir.scanbytype

A tiny abstraction to help use Kefir Observables for a flux-like pattern.

Installation

NPM

npm install kefir.scanbytype

Usage

import Kefir from 'kefir';
import scanByType from 'kefir.scanbytype';

var libraryEvents = [
  { type: 'CHECKOUT', title: 'The Cat in the Hat' },
  { type: 'TRANSFER_IN', title: 'Green Eggs and Ham' },
  { type: 'RETURN', title: 'The Lorax' },
  { type: 'CHECKOUT', title: 'Green Eggs and Ham' },
];

var initialState = {};
var reducer = scanByType({
  CHECKOUT:     (state, data) => { /* checkout logic */ },
  RETURN:       (state, data) => { /* return logic */ },
  TRANSFER_IN:  (state, data) => { /* transfer in logic */ },
  TRANSFER_OUT: (state, data) => { /* transfer out logic */ },
});

Kefir.sequentially(1000, events)
  .scan(reducer, initialState)
  .log();

With ES7 :: bind operator

import { scanByType } from 'kefir.scanByType';

var initalState = {};
var source = Kefir.sequentially(100, [0, 1, 2, 3]);
var result = source::scanByType({
  CHECKOUT(state, data) {
    return state;
  },
}, initialState)