denial-stream
Prevent unpiping on error in stream
Example
var denialStream = require('denial-stream')
var from = require('from2')
var through = require('through2')
var dataStream = from.obj([1, 2, 3, 4, 5, 6, 7])
var failStream = through.obj(function(chunk, enc, callback) {
if (chunk % 2) return callback(new Error('not cool'))
this.push(chunk + '')
callback()
})
failStream.on('error', function (err) {
console.log(err)
})
dataStream
.pipe(denialStream(failStream))
.pipe(process.stdout)
Usage
var d = denialStream(stream)
Wraps a readable/writable stream in a new stream
Events
d.on('deniedError', function (err) {})
The deniedError
event is emitted when the passed in stream emits an error. deniedStream
suppresses normal error
events to prevent the stream from unpiping
and instead forwards errors with the deniedError
event.
License
MIT