Class WriteStream

Hierarchy

  • Writable
    • WriteStream

Implements

  • WriteStream

Constructors

constructor

Properties

_readableState _writableState [asyncDispose] bytesWritten closed destroyed errored path pending readable readableFlowing readableHighWaterMark readableLength writable writableCorked writableEnded writableFinished writableHighWaterMark writableLength writableNeedDrain writableObjectMode

Methods

_destroy _final _read _undestroy _write _writev? [asyncIterator] addListener asIndexedPairs close compose cork destroy drop emit end eventNames every filter find flatMap forEach getMaxListeners isPaused iterator listenerCount listeners map off on once pause pipe prependListener prependOnceListener push rawListeners read reduce removeAllListeners removeListener resume setDefaultEncoding setEncoding setMaxListeners some take toArray uncork unpipe unshift wrap write

Constructors

constructor

  • new WriteStream(opts?): WriteStream

  • Parameters

    • Optionalopts: WritableOptions

    Returns WriteStream

Properties

_readableState

_readableState: ReadableState

_writableState

_writableState: WritableState

[asyncDispose]

[asyncDispose]: never

bytesWritten

bytesWritten: number

The number of bytes written so far. Does not include data that is still queued for writing.

Since

v0.4.7

Readonlyclosed

closed: boolean

destroyed

destroyed: boolean

Readonlyerrored

errored: null | Error

path

path: string | Buffer

The path to the file the stream is writing to as specified in the first argument to createWriteStream. If path is passed as a string, thenwriteStream.path will be a string. If path is passed as a Buffer, thenwriteStream.path will be a Buffer.

Since

v0.1.93

pending

pending: boolean

This property is true if the underlying file has not been opened yet, i.e. before the 'ready' event is emitted.

Since

v11.2.0

readable

readable: boolean

ReadonlyreadableFlowing

readableFlowing: null | boolean

ReadonlyreadableHighWaterMark

readableHighWaterMark: number

ReadonlyreadableLength

readableLength: number

writable

writable: boolean

ReadonlywritableCorked

writableCorked: never

ReadonlywritableEnded

writableEnded: never

ReadonlywritableFinished

writableFinished: never

ReadonlywritableHighWaterMark

writableHighWaterMark: number

ReadonlywritableLength

writableLength: number

ReadonlywritableNeedDrain

writableNeedDrain: boolean

ReadonlywritableObjectMode

writableObjectMode: never

Methods

_destroy

  • _destroy(error, callback): void

  • Parameters

    • error: null | Error
    • callback: ((error: null | Error) => void)
        • (error): void

        • Parameters

          • error: null | Error

          Returns void

    Returns void

_final

  • _final(callback): void

  • Parameters

    • callback: ((error?: null | Error) => void)
        • (error?): void

        • Parameters

          • Optionalerror: null | Error

          Returns void

    Returns void

_read

  • _read(size): void

  • Parameters

    • size: number

    Returns void

_undestroy

  • _undestroy(): void

  • Returns void

_write

  • _write(chunk, encoding, callback): void

  • Parameters

    • chunk: any
    • encoding: string
    • callback: ((error?: null | Error) => void)
        • (error?): void

        • Parameters

          • Optionalerror: null | Error

          Returns void

    Returns void

Optional_writev

  • _writev(chunks, callback): void

  • Parameters

    • chunks: {
          chunk: any;
          encoding: string;
      }[]
    • callback: ((error?: null | Error) => void)
        • (error?): void

        • Parameters

          • Optionalerror: null | Error

          Returns void

    Returns void

[asyncIterator]

  • [asyncIterator](): AsyncIterableIterator<any>

  • Returns AsyncIterableIterator<any>

addListener

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. drain
    3. error
    4. finish
    5. pipe
    6. unpipe

    Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • addListener(event, listener): this

  • Event emitter The defined events on documents including:

    1. close
    2. data
    3. end
    4. readable
    5. error

    Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

asIndexedPairs

  • asIndexedPairs(options?): Readable

  • Parameters

    • Optionaloptions: SignalOption

    Returns Readable

close

  • close(callback?): void

  • Closes writeStream. Optionally accepts a callback that will be executed once the writeStreamis closed.

    Parameters

    Returns void

    Since

    v0.9.4

compose

  • compose<T>(stream, options?): T

  • Type Parameters

    • T extends ReadableStream

    Parameters

    • stream:
          | ComposeFnParam
          | T
          | Iterable<T>
          | AsyncIterable<T>
    • Optionaloptions: {
          signal: AbortSignal;
      }
      • signal: AbortSignal

    Returns T

cork

  • cork(): void

  • Returns void

destroy

  • destroy(error?): this

  • Parameters

    • Optionalerror: Error

    Returns this

drop

  • drop(limit, options?): Readable

  • Parameters

    • limit: number
    • Optionaloptions: SignalOption

    Returns Readable

emit

  • emit(event): boolean

  • Parameters

    • event: "close"

    Returns boolean

  • emit(event): boolean

  • Parameters

    • event: "drain"

    Returns boolean

  • emit(event, err): boolean

  • Parameters

    • event: "error"
    • err: Error

    Returns boolean

  • emit(event): boolean

  • Parameters

    • event: "finish"

    Returns boolean

  • emit(event, src): boolean

  • Parameters

    • event: "pipe"
    • src: Readable

    Returns boolean

  • emit(event, src): boolean

  • Parameters

    • event: "unpipe"
    • src: Readable

    Returns boolean

  • emit(event, ...args): boolean

  • Parameters

    • event: string | symbol
    • Rest...args: any[]

    Returns boolean

end

  • end(cb?): this

  • Parameters

    • Optionalcb: (() => void)
        • (): void

        • Returns void

    Returns this

  • end(chunk, cb?): this

  • Parameters

    • chunk: any
    • Optionalcb: (() => void)
        • (): void

        • Returns void

    Returns this

  • end(chunk, encoding?, cb?): this

  • Parameters

    • chunk: any
    • Optionalencoding: string
    • Optionalcb: (() => void)
        • (): void

        • Returns void

    Returns this

eventNames

  • eventNames(): (string | symbol)[]

  • Returns (string | symbol)[]

every

  • every(fn, options?): Promise<boolean>

  • Parameters

    • fn: ((data: any, options?: SignalOption) => boolean | Promise<boolean>)
        • (data, options?): boolean | Promise<boolean>

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns boolean | Promise<boolean>

    • Optionaloptions: ArrayOptions

    Returns Promise<boolean>

filter

  • filter(fn, options?): Readable

  • Parameters

    • fn: ((data: any, options?: SignalOption) => boolean | Promise<boolean>)
        • (data, options?): boolean | Promise<boolean>

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns boolean | Promise<boolean>

    • Optionaloptions: ArrayOptions

    Returns Readable

find

  • find<T>(fn, options?): Promise<undefined | T>

  • Type Parameters

    • T

    Parameters

    • fn: ((data: any, options?: SignalOption) => data is T)
        • (data, options?): data is T

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns data is T

    • Optionaloptions: ArrayOptions

    Returns Promise<undefined | T>

  • find(fn, options?): Promise<any>

  • Parameters

    • fn: ((data: any, options?: SignalOption) => boolean | Promise<boolean>)
        • (data, options?): boolean | Promise<boolean>

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns boolean | Promise<boolean>

    • Optionaloptions: ArrayOptions

    Returns Promise<any>

flatMap

  • flatMap(fn, options?): Readable

  • Parameters

    • fn: ((data: any, options?: SignalOption) => any)
        • (data, options?): any

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns any

    • Optionaloptions: ArrayOptions

    Returns Readable

forEach

  • forEach(fn, options?): Promise<void>

  • Parameters

    • fn: ((data: any, options?: SignalOption) => void | Promise<void>)
        • (data, options?): void | Promise<void>

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns void | Promise<void>

    • Optionaloptions: ArrayOptions

    Returns Promise<void>

getMaxListeners

  • getMaxListeners(): number

  • Returns number

isPaused

  • isPaused(): boolean

  • Returns boolean

iterator

  • iterator(options?): AsyncIterableIterator<any>

  • Parameters

    • Optionaloptions: {
          destroyOnReturn?: boolean;
      }
      • OptionaldestroyOnReturn?: boolean

    Returns AsyncIterableIterator<any>

listenerCount

  • listenerCount(eventName): number

  • Parameters

    • eventName: string | symbol

    Returns number

listeners

  • listeners(eventName): Function[]

  • Parameters

    • eventName: string | symbol

    Returns Function[]

map

  • map(fn, options?): Readable

  • Parameters

    • fn: ((data: any, options?: SignalOption) => any)
        • (data, options?): any

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns any

    • Optionaloptions: ArrayOptions

    Returns Readable

off

  • off(eventName, listener): this

  • Parameters

    • eventName: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

on

  • on(event, listener): this

  • Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • on(event, listener): this

  • Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

once

  • once(event, listener): this

  • Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • once(event, listener): this

  • Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

pause

  • pause(): this

  • Returns this

pipe

  • pipe<T>(destination, options?): T

  • Type Parameters

    • T extends _IWritable

    Parameters

    • destination: T
    • Optionaloptions: {
          end?: boolean;
      }
      • Optionalend?: boolean

    Returns T

prependListener

  • prependListener(event, listener): this

  • Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • prependListener(event, listener): this

  • Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

prependOnceListener

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • prependOnceListener(event, listener): this

  • Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

push

  • push(chunk, encoding?): boolean

  • Parameters

    • chunk: any
    • Optionalencoding: string

    Returns boolean

rawListeners

  • rawListeners(eventName): Function[]

  • Parameters

    • eventName: string | symbol

    Returns Function[]

read

  • read(size?): any

  • Parameters

    • Optionalsize: number

    Returns any

reduce

  • reduce<T>(fn, initial?, options?): Promise<T>

  • Type Parameters

    • T = any

    Parameters

    • fn: ((previous: any, data: any, options?: Pick<ArrayOptions, "signal">) => T)
        • (previous, data, options?): T

        • Parameters

          • previous: any
          • data: any
          • Optionaloptions: Pick<ArrayOptions, "signal">

          Returns T

    • Optionalinitial: undefined
    • Optionaloptions: Pick<ArrayOptions, "signal">

    Returns Promise<T>

  • reduce<T>(fn, initial, options?): Promise<T>

  • Type Parameters

    • T = any

    Parameters

    • fn: ((previous: T, data: any, options?: Pick<ArrayOptions, "signal">) => T)
        • (previous, data, options?): T

        • Parameters

          • previous: T
          • data: any
          • Optionaloptions: Pick<ArrayOptions, "signal">

          Returns T

    • initial: T
    • Optionaloptions: Pick<ArrayOptions, "signal">

    Returns Promise<T>

removeAllListeners

  • removeAllListeners(event?): this

  • Parameters

    • Optionalevent: string | symbol

    Returns this

removeListener

  • removeListener(event, listener): this

  • Parameters

    • event: "close"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: "drain"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: "error"
    • listener: ((err: Error) => void)
        • (err): void

        • Parameters

          • err: Error

          Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: "finish"
    • listener: (() => void)
        • (): void

        • Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: "pipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: "unpipe"
    • listener: ((src: Readable) => void)
        • (src): void

        • Parameters

          • src: Readable

          Returns void

    Returns this

  • removeListener(event, listener): this

  • Parameters

    • event: string | symbol
    • listener: ((...args: any[]) => void)
        • (...args): void

        • Parameters

          • Rest...args: any[]

          Returns void

    Returns this

resume

  • resume(): this

  • Returns this

setDefaultEncoding

  • setDefaultEncoding(encoding): this

  • Parameters

    • encoding: string

    Returns this

setEncoding

  • setEncoding(encoding): this

  • Parameters

    • encoding: string

    Returns this

setMaxListeners

  • setMaxListeners(n): this

  • Parameters

    • n: number

    Returns this

some

  • some(fn, options?): Promise<boolean>

  • Parameters

    • fn: ((data: any, options?: SignalOption) => boolean | Promise<boolean>)
        • (data, options?): boolean | Promise<boolean>

        • Parameters

          • data: any
          • Optionaloptions: SignalOption

          Returns boolean | Promise<boolean>

    • Optionaloptions: ArrayOptions

    Returns Promise<boolean>

take

  • take(limit, options?): Readable

  • Parameters

    • limit: number
    • Optionaloptions: SignalOption

    Returns Readable

toArray

  • toArray(options?): Promise<any[]>

  • Parameters

    • Optionaloptions: SignalOption

    Returns Promise<any[]>

uncork

  • uncork(): void

  • Returns void

unpipe

  • unpipe(destination?): this

  • Parameters

    • Optionaldestination: Writable

    Returns this

unshift

  • unshift(chunk): void

  • Parameters

    • chunk: any

    Returns void

wrap

  • wrap(oldStream): this

  • Parameters

    • oldStream: Readable

    Returns this

write

  • write(chunk, cb?): boolean

  • Parameters

    • chunk: any
    • Optionalcb: ((error: undefined | null | Error) => void)
        • (error): void

        • Parameters

          • error: undefined | null | Error

          Returns void

    Returns boolean

  • write(chunk, encoding?, cb?): boolean

  • Parameters

    • chunk: any
    • Optionalencoding: string
    • Optionalcb: ((error: undefined | null | Error) => void)
        • (error): void

        • Parameters

          • error: undefined | null | Error

          Returns void

    Returns boolean

Settings

Member Visibility

On This Page

Constructors
Properties
Methods