Package detail

/**

• callbag-pipe

• ---

  *
• Utility function for plugging callbags together in chain. This utility
• actually doesn't rely on Callbag specifics, and is really similar to
• Ramda's pipe or lodash's flow.
• Implementation of callbag-pipe using R.pipe could look like this: *
• const pipe = (source, ...cbs) => R.pipe(...cbs)(source)
• This exists to play nicely with the ecosystem,
• and to facilitate the import of the function. *
• npm install callbag-pipe *
• Example: *
• Create a source with pipe, then pass it to a forEach: *
• const interval = require('callbag-interval');
• const forEach = require('callbag-for-each');
• const combine = require('callbag-combine');
• const pipe = require('callbag-pipe');
• const take = require('callbag-take');
• const map = require('callbag-map'); *
• const source = pipe(
• combine(interval(100), interval(350)),
• map(([x, y]) => X${x},Y${y}),
• take(10)
• ); *
• forEach(x => console.log(x))(source); // X2,Y0
• // X3,Y0
• // X4,Y0
• // X5,Y0
• // X6,Y0
• // X6,Y1
• // X7,Y1
• // X8,Y1
• // X9,Y1
• // X9,Y2 * *
• Or use pipe to go all the way from source to sink: *
• const interval = require('callbag-interval');
• const forEach = require('callbag-for-each');
• const combine = require('callbag-combine');
• const pipe = require('callbag-pipe');
• const take = require('callbag-take');
• const map = require('callbag-map'); *
• pipe(
• combine(interval(100), interval(350)),
• map(([x, y]) => X${x},Y${y}),
• take(10),
• forEach(x => console.log(x))
• );
• // X2,Y0
• // X3,Y0
• // X4,Y0
• // X5,Y0
• // X6,Y0
• // X6,Y1
• // X7,Y1
• // X8,Y1
• // X9,Y1
• // X9,Y2 * *
• Nesting

• ---

  *
• To use pipe inside another pipe, you need to give the inner pipe an
• argument, e.g. s => pipe(s, ...: *
• const interval = require('callbag-interval');
• const forEach = require('callbag-for-each');
• const combine = require('callbag-combine');
• const pipe = require('callbag-pipe');
• const take = require('callbag-take');
• const map = require('callbag-map'); *
• pipe(
• combine(interval(100), interval(350)),
• s => pipe(s,
• map(([x, y]) => X${x},Y${y}),
• take(10)
• ),
• forEach(x => console.log(x))
• ); * *
• This means you can use pipe to create a new operator: *
• const mapThenTake = (f, amount) =>
• s => pipe(s, map(f), take(amount)); *
• pipe(
• combine(interval(100), interval(350)),
• mapThenTake(([x, y]) => X${x},Y${y}, 10),
• forEach(x => console.log(x))
• ); * */

function pipe(...cbs) { let res = cbs[0]; for (let i = 1, n = cbs.length; i < n; i++) res = cbsi; return res; }

module.exports = pipe;