Skip to content

Utf8Stream

Defined in: src/node/utf8stream.ts:105

An optimized UTF-8 stream writer that allows for flushing all of the internal buffering on demand.

  • EventEmitter<fs.Utf8StreamEventMap>
  • EventEmitter
  • Utf8Stream

new Utf8Stream(options?): Utf8Stream

Defined in: src/node/utf8stream.ts:150

Utf8StreamOptions = {}

Utf8Stream

EventEmitter<fs.Utf8StreamEventMap>.constructor

constructor: typeof Utf8Stream

Defined in: src/node/utf8stream.ts:137

The initial value of Object.prototype.constructor is the standard built-in Object constructor.


static [kUtf8StreamFS]: FS = _utf8StreamFS

Defined in: src/node/utf8stream.ts:138


static prefixed: string | boolean

Defined in: node_modules/eventemitter3/index.d.ts:9

EventEmitter.prefixed

get append(): boolean

Defined in: src/node/utf8stream.ts:473

Whether the stream is appending to the file or truncating it

boolean

fs.Utf8Stream.append


get contentMode(): "buffer" | "utf8"

Defined in: src/node/utf8stream.ts:483

The type of data that can be written to the stream

"buffer" | "utf8"

fs.Utf8Stream.contentMode


get fd(): number

Defined in: src/node/utf8stream.ts:440

The file descriptor that is being written to

number

fs.Utf8Stream.fd


get file(): string

Defined in: src/node/utf8stream.ts:435

The file that is being written to

string

fs.Utf8Stream.file


get fsync(): boolean

Defined in: src/node/utf8stream.ts:468

Whether the stream performs a fsyncSync after every write

boolean

fs.Utf8Stream.fsync


get maxLength(): number

Defined in: src/node/utf8stream.ts:453

The maximum length of the internal buffer. If a write would cause the buffer to exceed this, the data is dropped and a drop event is emitted with it.

number

fs.Utf8Stream.maxLength


get minLength(): number

Defined in: src/node/utf8stream.ts:445

The minimum length of the internal buffer that is required to be full before flushing

number

fs.Utf8Stream.minLength


get mkdir(): boolean

Defined in: src/node/utf8stream.ts:488

Whether the directory for file is created if it does not exist

boolean

fs.Utf8Stream.mkdir


get mode(): Mode

Defined in: src/node/utf8stream.ts:430

The mode of the file that is being written to

Mode

fs.Utf8Stream.mode


get periodicFlush(): number

Defined in: src/node/utf8stream.ts:478

The number of milliseconds between flushes. 0 means no periodic flushes are performed.

number

fs.Utf8Stream.periodicFlush


get sync(): boolean

Defined in: src/node/utf8stream.ts:463

Whether the stream is writing synchronously or asynchronously

boolean

fs.Utf8Stream.sync


get writing(): boolean

Defined in: src/node/utf8stream.ts:458

Whether the stream is currently writing data to the file

boolean

fs.Utf8Stream.writing

[dispose](): void

Defined in: src/node/utf8stream.ts:492

void

fs.Utf8Stream.[dispose]


addListener<T>(event, fn, context?): this

Defined in: src/node/utf8stream.ts:739

T extends keyof Utf8StreamEventMap

T

(…args) => void

any

this

NodeEventEmitter.addListener

EventEmitter.addListener


destroy(): void

Defined in: src/node/utf8stream.ts:424

Close the stream immediately, without flushing the internal buffer.

void

fs.Utf8Stream.destroy


emit<T>(event, …args): boolean

Defined in: node_modules/eventemitter3/index.d.ts:32

Calls each of the listeners registered for a given event.

T extends keyof Utf8StreamEventMap

T

ArgumentMap<Utf8StreamEventMap>[Extract<T, keyof Utf8StreamEventMap>]

boolean

NodeEventEmitter.emit

EventEmitter.emit


end(): void

Defined in: src/node/utf8stream.ts:403

Close the stream gracefully, flushing the internal buffer before closing.

void

fs.Utf8Stream.end


eventNames(): keyof Utf8StreamEventMap[]

Defined in: node_modules/eventemitter3/index.d.ts:15

Return an array listing the events for which the emitter has registered listeners.

keyof Utf8StreamEventMap[]

NodeEventEmitter.eventNames

EventEmitter.eventNames


flush(cb?): void

Defined in: src/node/utf8stream.ts:285

Writes the current buffer to the file if a write was not in progress. Does nothing if minLength is zero or if it is already writing.

((err) => void) | null

void

fs.Utf8Stream.flush


flushSync(): void

Defined in: src/node/utf8stream.ts:315

Flushes the buffered data synchronously. This is a costly operation.

void

fs.Utf8Stream.flushSync


getMaxListeners(): never

Defined in: src/node/utf8stream.ts:760

Returns the current max listener value for the EventEmitter which is either set by emitter.setMaxListeners(n) or defaults to events.defaultMaxListeners.

never

v1.0.0

NodeEventEmitter.getMaxListeners


listenerCount(event): number

Defined in: node_modules/eventemitter3/index.d.ts:27

Return the number of listeners listening to a given event.

keyof Utf8StreamEventMap

number

NodeEventEmitter.listenerCount

EventEmitter.listenerCount


listeners<T>(event): (…args) => void[]

Defined in: node_modules/eventemitter3/index.d.ts:20

Return the listeners registered for a given event.

T extends keyof Utf8StreamEventMap

T

(…args) => void[]

NodeEventEmitter.listeners

EventEmitter.listeners


off<T>(event, fn?, context?, once?): this

Defined in: src/node/utf8stream.ts:748

T extends keyof Utf8StreamEventMap

T

(…args) => void

any

boolean

this

NodeEventEmitter.off

EventEmitter.off


on<T>(event, fn, context?): this

Defined in: src/node/utf8stream.ts:734

Add a listener for a given event.

T extends keyof Utf8StreamEventMap

T

(…args) => void

any

this

NodeEventEmitter.on

EventEmitter.on


once<T>(event, fn, context?): this

Defined in: src/node/utf8stream.ts:743

Add a one-time listener for a given event.

T extends keyof Utf8StreamEventMap

T

(…args) => void

any

this

NodeEventEmitter.once

EventEmitter.once


prependListener(): never

Defined in: src/node/utf8stream.ts:764

Adds the listener function to the beginning of the listeners array for the event named eventName. No checks are made to see if the listener has already been added. Multiple calls passing the same combination of eventName and listener will result in the listener being added, and called, multiple times.

server.prependListener('connection', (stream) => {
console.log('someone connected!');
});

Returns a reference to the EventEmitter, so that calls can be chained.

never

v6.0.0

NodeEventEmitter.prependListener


prependOnceListener(): never

Defined in: src/node/utf8stream.ts:768

Adds a one-time listener function for the event named eventName to the beginning of the listeners array. The next time eventName is triggered, this listener is removed, and then invoked.

server.prependOnceListener('connection', (stream) => {
console.log('Ah, we have our first user!');
});

Returns a reference to the EventEmitter, so that calls can be chained.

never

v6.0.0

NodeEventEmitter.prependOnceListener


rawListeners(): never

Defined in: src/node/utf8stream.ts:772

Returns a copy of the array of listeners for the event named eventName, including any wrappers (such as those created by .once()).

import { EventEmitter } from 'node:events';
const emitter = new EventEmitter();
emitter.once('log', () => console.log('log once'));
// Returns a new Array with a function `onceWrapper` which has a property
// `listener` which contains the original listener bound above
const listeners = emitter.rawListeners('log');
const logFnWrapper = listeners[0];
// Logs "log once" to the console and does not unbind the `once` event
logFnWrapper.listener();
// Logs "log once" to the console and removes the listener
logFnWrapper();
emitter.on('log', () => console.log('log persistently'));
// Will return a new Array with a single function bound by `.on()` above
const newListeners = emitter.rawListeners('log');
// Logs "log persistently" twice
newListeners[0]();
emitter.emit('log');

never

v9.4.0

NodeEventEmitter.rawListeners


removeAllListeners(event?): this

Defined in: node_modules/eventemitter3/index.d.ts:79

Remove all listeners, or those of the specified event.

keyof Utf8StreamEventMap

this

NodeEventEmitter.removeAllListeners

EventEmitter.removeAllListeners


removeListener<T>(event, fn?, context?, once?): this

Defined in: src/node/utf8stream.ts:752

Remove the listeners of a given event.

T extends keyof Utf8StreamEventMap

T

(…args) => void

any

boolean

this

NodeEventEmitter.removeListener

EventEmitter.removeListener


reopen(file?): void

Defined in: src/node/utf8stream.ts:372

Reopen the file in place, useful for log rotation.

PathLike

void

fs.Utf8Stream.reopen


setMaxListeners(): never

Defined in: src/node/utf8stream.ts:756

By default EventEmitters will print a warning if more than 10 listeners are added for a particular event. This is a useful default that helps finding memory leaks. The emitter.setMaxListeners() method allows the limit to be modified for this specific EventEmitter instance. The value can be set to Infinity (or 0) to indicate an unlimited number of listeners.

Returns a reference to the EventEmitter, so that calls can be chained.

never

v0.3.5

NodeEventEmitter.setMaxListeners


write(data): boolean

Defined in: src/node/utf8stream.ts:241

When contentMode is utf8, data must be a string. When it is buffer, data must be a Buffer.

string | Buffer<ArrayBufferLike>

boolean

Whether the internal buffer is below the high water mark

fs.Utf8Stream.write