const interleave = require('callbag-interleave');
const forEach = require('callbag-for-each');
const map = require('callbag-map');
const pipe = require('callbag-pipe');

pipe(
  interleave('abc', [1, 2, 3]),
  map(([k, v]) => ({ [k]: v })),
  forEach((x) => {
    console.log(x); // { a: 1 }
                    // { b: 2 }          
  })                // { c: 3 } and completes
);

const interleave = require('callbag-interleave');
const forEach = require('callbag-for-each');
const map = require('callbag-map');
const pipe = require('callbag-pipe');

pipe(
  interleave('ab', [1, 2, 3]),
  map(([k, v]) => ({ [k]: v })),
  forEach((x) => {
    console.log(x); // { a: 1 }
                    // { b: 2 } and completes          
  })
);