ZenFS
    Preparing search index...

    Class Utf8Stream

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

    Hierarchy

    • EventEmitter<fs.Utf8StreamEventMap>
      • Utf8Stream

    Implements

    • EventEmitter
    • Utf8Stream
    Index
    constructor: typeof Utf8Stream

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

    "[kUtf8StreamFS]": FS = _utf8StreamFS
    prefixed: string | boolean
    • get append(): boolean

      Whether the stream is appending to the file or truncating it

      Returns boolean

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

      The type of data that can be written to the stream

      Returns "buffer" | "utf8"

    • get fd(): number

      The file descriptor that is being written to

      Returns number

    • get file(): string

      The file that is being written to

      Returns string

    • get fsync(): boolean

      Whether the stream performs a fsyncSync after every write

      Returns boolean

    • get maxLength(): number

      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.

      Returns number

    • get minLength(): number

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

      Returns number

    • get mkdir(): boolean

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

      Returns boolean

    • get mode(): Mode

      The mode of the file that is being written to

      Returns Mode

    • get periodicFlush(): number

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

      Returns number

    • get sync(): boolean

      Whether the stream is writing synchronously or asynchronously

      Returns boolean

    • get writing(): boolean

      Whether the stream is currently writing data to the file

      Returns boolean

    • Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • fn: (...args: Utf8StreamEventMap[T]) => void
      • Optionalcontext: any

      Returns this

    • Close the stream immediately, without flushing the internal buffer.

      Returns void

    • Calls each of the listeners registered for a given event.

      Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • ...args: ArgumentMap<Utf8StreamEventMap>[Extract<T, keyof Utf8StreamEventMap>]

      Returns boolean

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

      Returns void

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

      Returns (keyof Utf8StreamEventMap)[]

    • 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.

      Parameters

      • Optionalcb: ((err: Error | null) => void) | null

      Returns void

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

      Returns void

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

      Returns never

      v1.0.0

    • Return the number of listeners listening to a given event.

      Parameters

      • event: keyof Utf8StreamEventMap

      Returns number

    • Return the listeners registered for a given event.

      Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T

      Returns (
          (
              ...args: ArgumentMap<Utf8StreamEventMap>[Extract<
                  T,
                  keyof Utf8StreamEventMap,
              >],
          ) => void
      )[]

    • Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • Optionalfn: (...args: any[]) => void
      • Optionalcontext: any
      • Optionalonce: boolean

      Returns this

    • Add a listener for a given event.

      Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • fn: (...args: Utf8StreamEventMap[T]) => void
      • Optionalcontext: any

      Returns this

    • Add a one-time listener for a given event.

      Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • fn: (...args: Utf8StreamEventMap[T]) => void
      • Optionalcontext: any

      Returns this

    • 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.

      Returns never

      v6.0.0

    • 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.

      Returns never

      v6.0.0

    • 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');

      Returns never

      v9.4.0

    • Remove all listeners, or those of the specified event.

      Parameters

      • Optionalevent: keyof Utf8StreamEventMap

      Returns this

    • Remove the listeners of a given event.

      Type Parameters

      • T extends keyof Utf8StreamEventMap

      Parameters

      • event: T
      • Optionalfn: (...args: any[]) => void
      • Optionalcontext: any
      • Optionalonce: boolean

      Returns this

    • Reopen the file in place, useful for log rotation.

      Parameters

      • Optionalfile: PathLike

      Returns void

    • 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.

      Returns never

      v0.3.5

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

      Parameters

      • data: string | Buffer<ArrayBufferLike>

      Returns boolean

      Whether the internal buffer is below the high water mark