pull-timeout2
v0.0.2
Published
abort a pull-stream if the rate of flow drops below the specified threshold.
Downloads
10
Readme
pull-timeout2
Abort a pull-stream if the rate of flow drops below the specified threshold. Uses setTimeout()
under-the-hood.
example
var pull = require('pull-stream')
var timeout = require('pull-timeout2')
var delay = 500
pull(
pull.values([1, 2, 3, 4, 5, 6, 7, 8]),
pull.asyncMap(function (num, next) {
setTimeout(() => next(null, num), num * 100)
}),
timeout(delay),
pull.log() // 1 2 3 4 5 <end>
)
license
License Zero Reciprocal Public License 2.0.1