streamqueue

StreamQueue pipe the queued streams one by one in order to preserve their content order.

Usage

Install the npm module:

1npm install streamqueue --save

Then, in your scripts:

1import { StreamQueue } from 'streamqueue';
2import { createReadStream } from 'node:fs';
3
4const queue = new StreamQueue(
5  createReadStream('input.txt'),
6  createReadStream('input2.txt'),
7  createReadStream('input3.txt'),
8).pipe(process.stdout);

StreamQueue also accept functions returning streams, the above can be written like this, doing system calls only when piping:

1import { queueStreams } = require('streamqueue');
2import { createReadStream } from 'node:fs';
3
4const queue = queueStreams(
5  createReadStream.bind(null, 'input.txt'),
6  createReadStream.bind(null, 'input2.txt'),
7  createReadStream.bind(null, 'input3.txt'),
8).pipe(process.stdout);

Object-oriented traditionnal API offers more flexibility:

1import { StreamQueue } from 'streamqueue';
2import { createReadStream } from 'node:fs';
3
4const queue = new StreamQueue();
5
6queue.queue(
7  createReadStream('input.txt'),
8  createReadStream('input2.txt'),
9  createReadStream('input3.txt'),
10);
11queue.done();
12
13queue.pipe(process.stdout);

You can also chain StreamQueue methods like that:

1import StreamQueue from 'streamqueue';
2import { createReadStream } from 'node:fs';
3
4new StreamQueue()
5  .queue(createReadStream('input.txt'))
6  .queue(createReadStream('input2.txt'))
7  .queue(createReadStream('input3.txt'))
8  .done()
9  .pipe(process.stdout);

You can queue new streams at any moment until you call the done() method. So the created stream will not fire the end event until done() call.

Stats

Contributing

Feel free to propose your code if you agree with publishing it under the MIT license.

API

Classes

StreamQueue

Pipe queued streams sequentially

Functions

queueObjectStreams(options, ...streams) ⇒

Create a new queue in object mode and pipe given streams and end if some

queueStreams(options, ...streams) ⇒

Create a new queue and pipe given streams and end if some

StreamQueue

Pipe queued streams sequentially

Kind: global class

• StreamQueue
  • new StreamQueue(options, ...streams)
  • .queue(...streams) ⇒
  • .done(...streams) ⇒

new StreamQueue(options, ...streams)

Create a new queue and pipe given streams and end if some

Returns: StreamQueue

Param	Type	Description
options	Object	The queue options
options.objectMode	boolean	Operate in object mode
options.pauseFlowingStream	boolean	Pause given streams that are flowing
options.resumeFlowingStream	boolean	Resume given streams that are flowing
...streams	Readable | function	The stream or stream returning function to pipe in

streamQueue.queue(...streams) ⇒

Queue each stream given in argument

Kind: instance method of StreamQueue
Returns: StreamQueue

Param	Type	Description
...streams	Readable | function	The stream or stream returning function to pipe in

streamQueue.done(...streams) ⇒

Queue each stream given in argument and end

Kind: instance method of StreamQueue
Returns: StreamQueue

Param	Type	Description
...streams	Readable | function	The stream or stream returning function to pipe in

queueObjectStreams(options, ...streams) ⇒

Create a new queue in object mode and pipe given streams and end if some

Kind: global function
Returns: StreamQueue

Param	Type	Description
options	Object	The queue options
...streams	Readable | function	The stream or stream returning function to pipe in

queueStreams(options, ...streams) ⇒

Create a new queue and pipe given streams and end if some

Kind: global function
Returns: StreamQueue

Param	Type	Description
options	Object	The queue options
...streams	Readable | function	The stream or stream returning function to pipe in

Authors

• Nicolas Froidure

License

MIT