@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('@ljharb/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('@ljharb/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('@ljharb/through')

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

Changelog

v2.3.14 - 2025-02-07

Commits

• [types] any falsy value is allowed as write or end 0cc4d4d
• [Dev Deps] update @arethetypeswrong/cli, @ljharb/eslint-config, @ljharb/tsconfig, @types/node, @types/tape, auto-changelog, tape a51fc2c
• [Deps] update call-bind 78eabe4
• [Tests] replace aud with npm audit 908d64a
• [Dev Deps] add missing peer dep 80f3805