cc
callbag-concat
npm i callbag-concat
cc

callbag-concat

👜 Callbag factory that concatenates data from multiple callbag sources

by André Staltz

1.2.1 (see all)License:MITTypeScript:Not Found
npm i callbag-concat
Readme

'use strict';

/**

  • callbag-concat

  • Callbag factory that concatenates the data from multiple (2 or more)
  • callbag sources. It starts each source at a time: waits for the previous
  • source to end before starting the next source. Works with both pullable
  • and listenable sources.
  • npm install callbag-concat
  • Example:
  • const fromIter = require('callbag-from-iter');
    
  • const iterate = require('callbag-iterate');
    
  • const concat = require('callbag-concat');
    
  • const source = concat(fromIter([10,20,30]), fromIter(['a','b']));
    
  • iterate(x => console.log(x))(source); // 10
    
  •                                       // 20
    
  •                                       // 30
    
  •                                       // a
    
  •                                       // b
    
    */

const UNIQUE = {};

const concat = (...sources) => (start, sink) => { if (start !== 0) return; const n = sources.length; if (n === 0) { sink(0, () => {}); sink(2); return; } let i = 0; let sourceTalkback; let lastPull = UNIQUE; const talkback = (t, d) => { if (t === 1) lastPull = d; sourceTalkback(t, d); }; (function next() { if (i === n) { sink(2); return; } sources[i](0, (t, d) => { if (t === 0) { sourceTalkback = d; if (i === 0) sink(0, talkback); else if (lastPull !== UNIQUE) sourceTalkback(1, lastPull); } else if (t === 2 && d) { sink(2, d); } else if (t === 2) { i++; next(); } else { sink(t, d); } }); })(); };

module.exports = concat;

Downloads/wk

3K

GitHub Stars

6

LAST COMMIT

4yrs ago

MAINTAINERS

2

CONTRIBUTORS

4

OPEN ISSUES

0

OPEN PRs

0
VersionTagPublished
1.2.1
latest
4yrs ago
No alternatives found
No tutorials found
Add a tutorial

Rate & Review

100
No reviews found
Be the first to rate