Class DeferredQueue

constructor

• new DeferredQueue(opts?: { globalLimit?: number }): DeferredQueue

  Parameters

  • Optionalopts: { globalLimit?: number } = {}

    • OptionalglobalLimit?: number

      Total entry cap across all subscribers.

  Returns DeferredQueue

_buckets

globalLimit

drain

• drain(subscriberHash: Uint8Array<ArrayBufferLike>): PendingBlob[]

  Drains and returns all pending blobs for a subscriber (FIFO).

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>

  Returns PendingBlob[]

drainBatch

• drainBatch(
      subscriberHash: Uint8Array<ArrayBufferLike>,
      max: number,
  ): PendingBlob[]

  Drains at most max blobs for a subscriber (FIFO), leaving any remainder.

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>
  • max: number

  Returns PendingBlob[]

drainChannelBatch

• drainChannelBatch(
      subscriberHash: Uint8Array<ArrayBufferLike>,
      channelHash: Uint8Array<ArrayBufferLike>,
      max: number,
  ): PendingBlob[]

  Drains at most max blobs for (subscriber, channel) (FIFO). Non-matching blobs stay queued in their original relative order. This is the /rfed/pull paging primitive.

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>
  • channelHash: Uint8Array<ArrayBufferLike>
  • max: number

  Returns PendingBlob[]

enqueue

• enqueue(
      subscriberHash: Uint8Array<ArrayBufferLike>,
      channelHash: Uint8Array<ArrayBufferLike>,
      blob: Uint8Array<ArrayBufferLike>,
      perSubscriberLimit: number,
  ): void

  Enqueues a blob for an unreachable subscriber.

  Per-subscriber overflow drops the oldest; the global cap back-pressures (the enqueue is silently skipped).

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>
  • channelHash: Uint8Array<ArrayBufferLike>
  • blob: Uint8Array<ArrayBufferLike>
  • perSubscriberLimit: number

  Returns void

evictExpired

• evictExpired(maxAgeSec: number): number

  Drops entries older than maxAgeSec (SPEC §7: 7-day periodic prune).

  Parameters

  • maxAgeSec: number

  Returns number

  count evicted.

exportRecords

• exportRecords(): {
      blob: Uint8Array;
      channelHash: Uint8Array;
      enqueuedAt: number;
      subscriberHash: Uint8Array;
  }[]

  Exports every pending blob as serializable records (grouped by subscriber). Used by the @reticulum/node FS adapter.

  Returns {
      blob: Uint8Array;
      channelHash: Uint8Array;
      enqueuedAt: number;
      subscriberHash: Uint8Array;
  }[]

hasPending

• hasPending(subscriberHash: Uint8Array<ArrayBufferLike>): boolean

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>

  Returns boolean

hasPendingChannel

• hasPendingChannel(
      subscriberHash: Uint8Array<ArrayBufferLike>,
      channelHash: Uint8Array<ArrayBufferLike>,
  ): boolean

  Parameters

  • subscriberHash: Uint8Array<ArrayBufferLike>
  • channelHash: Uint8Array<ArrayBufferLike>

  Returns boolean

importRecords

• importRecords(
      records: {
          blob: Uint8Array;
          channelHash: Uint8Array;
          enqueuedAt: number;
          subscriberHash: Uint8Array;
      }[],
  ): void

  Replaces the queue with the given records (direct population, used on load). Clears any existing buckets first.

  Parameters

  • records: {
        blob: Uint8Array;
        channelHash: Uint8Array;
        enqueuedAt: number;
        subscriberHash: Uint8Array;
    }[]

  Returns void

totalLen

• totalLen(): number

  Total entries across all subscribers.

  Returns number