callbag-flatten-iter v1.0.3

yarn add callbag-flatten-iter

const pipe = require("callbag-pipe");
const fromIter = require("callbag-from-iter");
const flattenIter = require("callbag-flatten-iter");
const forEach = require("callbag-for-each");

pipe(
  fromIter([[10], [20], [30], [40, 50, 60]]),
  flattenIter,
  forEach(i => {
    // called 6 times
  })
);

If you're blessed with the pipeline operator:

fromIter([[10], [20], [30], [40, 50, 60]])
  |> flattenIter
  |> forEach(i => {
    // called 6 times
  });

Learn more

• Callbag basics
• Why we need callbags, by André Staltz