Nascent Plasticine Materialist
Learn about our RFC process, Open RFC meetings & more.Join in the discussion! »

encapsulate-streams

1.0.1 • Public • Published

encapsulate-streams Build status npm version codecov

Offer a pipeline of multiple transform streams as a single, encapsulating transform stream

Install

npm install encapsulate-streams

Use

import encapsulateStreams from 'encapsulate-streams'
import { Readable, Transform, Writable } from 'readable-stream'
 
function readable<O>(f: () => O): Readable {
    return new Readable({
        objectMode: true,
        read() {
            this.push(f())
        }
    })
}
 
function transform<I, O>(f: (chunk: I) => O): Transform {
    return new Transform({
        objectMode: true,
        // eslint-disable-next-line @typescript-eslint/no-explicit-any
        transform(chunk: I, _: string, callback: (error?: Error, data?: any) => void) {
            const result: O = f(chunk)
            this.push(result)
            callback()
        }
    })
}
 
function writable<I, O>(f: (chunk: I) => O): Writable {
    return new Writable({
        objectMode: true,
        write(chunk: I, _: string, callback: (error?: Error \| null) => void) {
            f(chunk)
            callback()
        }
    })
}
 
function main() {
 
    const elements = [0, 1, 2, 3, null]
    let index = 0
    const source = readable(() => elements[index++])
 
    const transform1 = transform((value: number) => value + 1)
    const transform2 = transform((value: number) => value * 10)
 
    const witness: number[] = []
    const sink = writable((value: number) => witness.push(value))
 
    const stream = encapsulateStreams(transform1, transform2)
    source.pipe(stream).pipe(sink)
 
    sink.on('finish', () => {
        console.log(witness)
    })
 
}
 
main()
//=>[ 10, 20, 30, 40 ]

Index

Functions


Functions

encapsulateStreams

encapsulateStreams(...streams: Transform[]): Transform

Defined in encapsulate-streams.ts:16

Encapsulate multiple transform-streams as a single, encapsulating transform stream.

Parameters:

Name Type Description
Rest streams Transform[] Streams to encapsulate

Returns: Transform A transform-stream encapsulating given streams


Install

npm i encapsulate-streams

DownloadsWeekly Downloads

3

Version

1.0.1

License

ISC

Unpacked Size

10.1 kB

Total Files

6

Last publish

Collaborators

  • avatar