@ljharb/through

@ljharb/through

Note: This package is a fork of https://npmjs.com/through, and builds off of it.

Easy way to create a Stream that is both readable and writable.

• Pass in optional write and end methods.
• through takes care of pause/resume logic if you use this.queue(data) instead of this.emit('data', data).
• Use this.pause() and this.resume() to manage flow.
• Check this.paused to see current flow state. (write always returns !this.paused).

This function is the basis for most of the synchronous streams in event-stream.

var through = require('through')

through(function write(data) {
    this.queue(data) //data *must* not be null
  },
  function end () { //optional
    this.queue(null)
  })

Or, can also be used without buffering on pause, use this.emit('data', data), and this.emit('end')

var through = require('through')

through(function write(data) {
    this.emit('data', data)
    //this.pause()
  },
  function end () { //optional
    this.emit('end')
  })

Extended Options

You will probably not need these 99% of the time.

autoDestroy=false

By default, through emits close when the writable and readable side of the stream has ended. If that is not desired, set autoDestroy=false.

var through = require('through')

//like this
var ts = through(write, end, {autoDestroy: false})
//or like this
var ts = through(write, end)
ts.autoDestroy = false

License

MIT / Apache2

Changelog

v2.3.9 - 2023-07-17

Commits

• [meta] add scripts, dev deps, linting; switch from travis to GHA 2bc7e2d
• [meta] rename package to scoped 337610b
• [meta] confirmed with dominictarr in writing that this package was only ever MIT 832061e
• [Dev Deps] update from, stream-spec, tape dae9dda
• [meta] fix auto-changelog start version 3ac451b
• [Fix] node < v0.6 does not have stream === stream.Stream 9f72162

<!-- auto-changelog-above -->