Novices Performing Miracles


    2.0.0 • Public • Published


    Callbag operator implementing switchMap, allowing you to map each element of a source callbag to a new callbag, and optionally to custom-collapse each pair of original/new elements into a final source callbag. (Unlike flatMap, this operator will eagerly switch to new callbags as they emit. If your callbags are pullable only, then there's no difference, but if all callbags are listenables, you might need a proper flatMap.)

    This library contains a single function that implements the example in callbag-flatten's README showing the basic pattern of calling map inside map, and then flattening. That is, this library's implementation is a combination of existing callbag operators (namely, pipe, map, and flatten), so there is absolutely no magic here.

    This operator was originally published as callbag-flat-map-operator but was renamed.


    In a Node.js project, run

    $ npm install --save callbag-switch-map-operator

    API and examples

    const switchmap = require('callbag-switch-map-operator');

    switchmap(mapper[, flattener = (a, b) => b])

    I think it's much easier to see what this does with examples, but I'll try to formalize this: with an abuse of TypeScript notation, this can be notionally described as:

    switchmap(mapper: A => Callbag<B>, flattener?: (A, B) => C)(source: Callbag<A>): Callbag<C>

    That is, switchmap is a callbag operator (a higher-order function) that takes up to two functions:

    • a mapper maps each emission of a source callbag and converts it to a new callbag, and
    • a flattener that maps each pair of values from the original source callbag and the callbag spawned from it to a final value,

    and produces a new source callbag that emits the outputs of flattener. By default, flattener = (a, b) => b, that is, the returned callbag will just emit a flattened stream of all callbags created by the mapper, but by overriding this you can achieve all sorts of useful behavior.

    An example will hopefully be much more illuminating. This shows how we can repeatedly use the outputs of switchmap in more switchmaps, and shows a couple of uses for flattener (for this example, be sure to run npm install callbag-basics):

    const switchmap = require('callbag-flat-map-operator');
    const { pipe, fromIter, forEach } = require('callbag-basics'); // npm i callbag-basics
    const years = [ 2017, 2016 ];
    const urls = 'users,edits'.split(',');
    const langs = 'en,zh'.split(',');
    // This is the Cartesian product of {years, urls, langs}, so 2 * 2 * 2 elements will be emitted
    const parametersCallbag = pipe(
            _ => fromIter(years),
            (url, year) => [url, year],
            _ => fromIter(langs),
            ([ url, year ], lang) => [url, year, lang],
    const parametersToEndpoints = (url, year, lang) => Array.from(Array(2), (_, i) => `/${url}/${year}/${lang}-v${i + 1}`);
    const resultsCallbag = pipe(
            ([ url, year, lang ]) => fromIter(parametersToEndpoints(url, year, lang)),
            (_, res) => res, // optional, this is the default
        forEach(x => console.log(x)),
    // /users/2017/en-v1
    // /users/2017/en-v2
    // /users/2017/zh-v1
    // /users/2017/zh-v2
    // /users/2016/en-v1
    // /users/2016/en-v2
    // /users/2016/zh-v1
    // /users/2016/zh-v2
    // /edits/2017/en-v1
    // /edits/2017/en-v2
    // /edits/2017/zh-v1
    // /edits/2017/zh-v2
    // /edits/2016/en-v1
    // /edits/2016/en-v2
    // /edits/2016/zh-v1
    // /edits/2016/zh-v2



    npm i callbag-switch-map-operator

    DownloadsWeekly Downloads






    Unpacked Size

    11.5 kB

    Total Files


    Last publish


    • fasiha