pull-abortable

a pull-stream that may be aborted from the outside.

example

1var pull = require('pull-stream')
2var Abortable = require('pull-abortable')
3
4var abortable = Abortable()
5pull(
6  source,
7  abortable,
8  sink
9)
10//at any time you can abort the pipeline,
11//the source will be cleaned up, and any
12//error will be passed to the sink next time it reads.
13atAnyTime(function () {
14  abortable.abort()
15})
16
17// abort the stream and end with an error
18abortable.abort(new Error('example'))

License

MIT