simplified stream construction
npm install @ljharb/throughNote: This package is a fork of https://npmjs.com/through, and builds off of it.
[![github actions][actions-image]][actions-url]
[![coverage][codecov-image]][codecov-url]
[![License][license-image]][license-url]
[![Downloads][downloads-image]][downloads-url]
[![npm badge][npm-badge-png]][package-url]
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.
`` js
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')
` js
var through = require('@ljharb/through')
through(function write(data) {
this.emit('data', data)
//this.pause()
},
function end () { //optional
this.emit('end')
})
`
You will probably not need these 99% of the time.
By default, through emits close when the writableautoDestroy=false
and readable side of the stream has ended.
If that is not desired, set .
` js
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
``
[package-url]: https://npmjs.org/package/@ljharb/through
[npm-version-svg]: https://versionbadg.es/ljharb/through.svg
[deps-svg]: https://david-dm.org/ljharb/through.svg
[deps-url]: https://david-dm.org/ljharb/through
[dev-deps-svg]: https://david-dm.org/ljharb/through/dev-status.svg
[dev-deps-url]: https://david-dm.org/ljharb/through#info=devDependencies
[npm-badge-png]: https://nodei.co/npm/@ljharb/through.png?downloads=true&stars=true
[license-image]: https://img.shields.io/npm/l/@ljharb/through.svg
[license-url]: LICENSE
[downloads-image]: https://img.shields.io/npm/dm/@ljharb/through.svg
[downloads-url]: https://npm-stat.com/charts.html?package=@ljharb/through
[codecov-image]: https://codecov.io/gh/ljharb/through/branch/main/graphs/badge.svg
[codecov-url]: https://app.codecov.io/gh/ljharb/through/
[actions-image]: https://img.shields.io/endpoint?url=https://github-actions-badge-u3jn4tfpocch.runkit.sh/ljharb/through
[actions-url]: https://github.com/ljharb/through/actions