A callbag operator that passes through only sequences with minimum length.
// minimum streak length = 3
1, 2, 2, 2, 2, 3, 3, 1, 1, 1, 3 // input
2, 2, 2, 2, 1, 1, 1 // output
npm install callbag-keep-sequences
const pipe = require('callbag-pipe')
const fromIter = require('callbag-from-iter')
const keepSequences = require('callbag-keep-sequences')
const forEach = require('callbag-for-each')
pipe(
fromIter([1, 2, 2, 2, 2, 3, 3, 1, 1, 1, 3]),
keepSequences(2), // sequences with >= 2 items
forEach(console.log)
)
// 2 2 2 2 1 1 1
keepSequences(n, compare = (a, b) => a === b)
- callbag spec – 👜 A standard for JS callbacks that enables lightweight observables and iterables
callbag-distinct-until-changed
– Drops consecutive duplicate values. Works on either pullable or listenable sources.
If you have a question or have difficulties using callbag-keep-sequences
, please double-check your code and setup first. If you think you have found a bug or want to propose a feature, refer to the issues page.