fanout-streams

Logical grouping of writable-streams in parallel

Install

npm install fanout-streams

Use

import { fanoutStreams } from 'fanout-streams'

import { Readable, Writable } from 'readable-stream'

const sink1 = new Writable({
    objectMode: true,
    write(chunk: string, _: string, callback: (error?: Error \| null) => void) {
        console.log('1:', chunk)
        callback()
    }
})

const sink2 = new Writable({
    objectMode: true,
    write(chunk: string, _: string, callback: (error?: Error \| null) => void) {
        console.log('2:', chunk)
        callback()
    }
})

const sink3 = new Writable({
    objectMode: true,
    write(chunk: string, _: string, callback: (error?: Error \| null) => void) {
        console.log('3:', chunk)
        callback()
    }
})

const stream = fanoutStreams(sink1, sink2, sink3)

const publisher = new Readable({objectMode: true, read() {}})
publisher.pipe(stream)

publisher.push('cat')
//=>1: cat
//=>2: cat
//=>3: cat

Related

Logical grouping of transform-streams in series: encapsulate-streams

Index

Functions

• fanoutStreams

Functions

fanoutStreams

▸ fanoutStreams(...streams: Writable[]): Writable

Defined in fanout-streams.ts:13

Return a single writable stream that fans received chunks out to each input-stream.

Parameters:

| Name | Type | | ------ | ------ | | Rest streams | Writable[] |

Returns: Writable