Kefir flux store example

KefirFluxStore.js

let Kefir = require("kefir");

function BlogStore(actions, initialState) {

    //map the action stream to a stream which returns a function which modifies the state.
    let createPost = actions.Post.create.map((newPost) => {
        
        //the scan method will call this with the current vaule (allPosts)
        return (allPosts) => {
            allPosts.push(newPost);
            return allPosts;
        }
    });

    //alt way of writing.
    //let createPost = actions.Posts.create.map((newPost) => (allPosts) => {
    //    allPosts.push(newPost);
    //    return allPosts;
    //});

    let posts = Kefir
        .merge([createPost])
        .scan((allPosts, mod) => mod(allPosts), initialState)
        .toProperty();

    return {
        posts
    }

}

module.exports = BlogStore;