node-liblzma - v3.1.2
    Preparing search index...

    Class LZMAPool

    LZMA Pool with concurrency control and event monitoring

    Provides rate limiting and backpressure for LZMA operations. Emits events for monitoring and metrics collection in production.

    const pool = new LZMAPool(10); // Max 10 concurrent operations

    pool.on('metrics', (metrics) => {
    console.log(`Active: ${metrics.active}, Queued: ${metrics.queued}`);
    });

    const compressed = await pool.compress(buffer);

    Events:

    • 'queue': Emitted when task added to queue
    • 'start': Emitted when task starts processing
    • 'complete': Emitted when task completes successfully
    • 'error-task': Emitted when task fails
    • 'metrics': Emitted after each state change with current metrics

    Hierarchy

    • EventEmitter
      • LZMAPool
    Index

    Constructors

    • Create a new LZMA pool

      Parameters

      • maxConcurrent: number = 10

        Maximum number of concurrent operations (default: 10)

      Returns LZMAPool

    Accessors

    • get activeCount(): number

      Get number of currently active tasks

      Returns number

      Active task count

    • get isAtCapacity(): boolean

      Check if pool is at maximum capacity

      Returns boolean

      True if at capacity

    • get queueLength(): number

      Get number of tasks waiting in queue

      Returns number

      Queue length

    Methods

    • Clear all pending tasks from the queue Active tasks will continue to run

      Returns number

      Number of tasks removed from queue

    • Compress data with automatic queue management

      Parameters

      • data: Buffer

        Buffer to compress

      • Optionalopts: LZMAOptions

        LZMA compression options

      Returns Promise<Buffer<ArrayBufferLike>>

      Promise that resolves to compressed buffer

    • Decompress data with automatic queue management

      Parameters

      • data: Buffer

        Compressed buffer to decompress

      • Optionalopts: LZMAOptions

        LZMA decompression options

      Returns Promise<Buffer<ArrayBufferLike>>

      Promise that resolves to decompressed buffer

    • Wait for all active tasks to complete Does not process new tasks added while waiting

      Returns Promise<void>

      Promise that resolves when all active tasks are done