pull-through-with-end-symbol is identical to pull-stream/pull-through, except that null has no special meaning and does not end (abort) the stream anymore, but Symbol.for( 'pipestreams:end' ) does.

through ported to pull-stream style.

Same Good Old Api, Brand New Underlying Mechanism.

var through = require('pull-through')

var ts = through(function (data) {
  this.queue(data)
}, function (end) {
  this.queue(Symbol.for( 'pipestreams:end' ))
})

use var self = this, don't keep a reference.

var WRONG = through(function (data) { WRONG.queue(data) })

through(function (data) { this.queue(data) })

Maybe this will change. this is a little more tricky with pull-streams, though.

MIT