Skip to content

Various functions for working with streams inside async functions

License

Notifications You must be signed in to change notification settings

NotWoods/promise-stream-utils

Repository files navigation

promise-stream-utils Build Status npm PRs Welcome

Various functions for working with streams inside async functions.

Awaiting stream events

Creates promises that resolve once the event has fired, and reject if an error event is fired.

ended

Resolves when the 'end' event fires, rejects when the 'error' event fires

function ended(stream: NodeJS.ReadableStream): Promise<void>;

finished

Resolves when the 'finish' event fires, rejects when the 'error' event fires

function finished(stream: NodeJS.WritableStream): Promise<void>;

Special stream classes

Special versions of the Readable, Writable, Duplex, and Transform stream classes where async functions are used rather than functions with a callback.

Exported as:

  • PromiseReadable
  • PromiseWritable
  • PromiseDuplex
  • PromiseTransform

Create a stream using these classes by calling new PromiseReadable(opts), and set the stream function inside options.

Other utility functions

toBuffer

Loads an entire stream's contents into a buffer in memory

function toBuffer(stream: NodeJS.ReadableStream): Promise<Buffer>;

About

Various functions for working with streams inside async functions

Topics

Resources

License

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published