effect-io-ai

Package: effect
Module: PubSub

PubSub.PubSub.Atomic

Low-level atomic PubSub interface that handles the core message storage and retrieval.

Signature

export interface Atomic<in out A> {
    readonly capacity: number
    isEmpty(): boolean
    isFull(): boolean
    size(): number
    publish(value: A): boolean
    publishAll(elements: Iterable<A>): Array<A>
    slide(): void
    subscribe(): BackingSubscription<A>
    replayWindow(): ReplayWindow<A>
  }

Source

Since v4.0.0