@rdmt-studios/blazing-buffer

blazing-buffer-typescript

Lightweight fully functional queue-like buffer for a specific task pool where it's used as an ordered buffer where data takeout rate almost the same as embedding or timings are optimized

install

npm i @rdmt-studios/blazing-buffer

Safe method passing

Buffer does not implemented as an object, it's just an interface to access function scope data, that's why methods does not depend on context, so you wound never face a context loss when passing method as an argument (callback), it's safe.

For example you can hide full interface from entity, giving it access only to use send or flush method.

class CustomAlerter extends HTMLElement {
  constructor(bufferSender: (data: string) => void) {
    super();
    this.onclick = bufferSender('clicked');
  };
};

class CustomConsole extends HTMLElement {
  constructor(bufferFlusher: () => string[]) {
    super();
    const button = customConsole.createDisplayButton();
    button.onclick = () => {
      this.textContent = bufferFlusher().join('\n');
    };
    this.appendChild(button);
  };

  private static createDisplayButton(): HTMLButtonElement {
    const node = document.createElement('button');
    node.textContent = 'Flush buffer';
    return node;
  };
};

function createConsole(): void {
  const buffer = createDataBuffer<string>();

  documen.body.append(
    new CustomAlerter(buffer.send),
    new CustomConsole(buffer.flush),
  );
}

Usage

Creating new buffer

const buffer = createDataBuffer<yourType>();

It does not have any underlying overhead or another function calls, so feel free not to go inspecting source files

Store

send(data: T) method puts data to buffer, saving order, time complexity O(const)

buffer.send(yourTypeData1);

Read

read(data: T): void takes out oldest stored data in buffer and removes it,time complexity O(const)

const data = buffer.read();
if (data !== undefined) {
  // buffer does not contain yourTypeData1 anymore
  // typeof data === 'yourType'...
}

Flush

flush(): T[] method clears buffer and returns it's "dump" as array, ordered is saved so elements is stored as they were stored in buffer, time complexity O(n)

buffer.send(yourTypeData2);
buffer.send(yourTypeData3);
buffer.send(yourTypeData4);

const buffer_dump: yourType[] = buffer.flush();
// buffer is empty...

Alternative way of reading

buffer.flush().forEach((data) => ...);

Package api

Buffer contstructor

import {createDataBuffer} from 'blazing-buffer'

Buffer interface type

import {DataBufferQueue} from 'blazing-buffer'