effect-io-ai

Package: effect
Module: PubSub

PubSub.PubSub.BackingSubscription

Low-level subscription interface that handles message polling for individual subscribers.

Signature

export interface BackingSubscription<out A> {
    isEmpty(): boolean
    size(): number
    poll(): A | MutableList.Empty
    pollUpTo(n: number): Array<A>
    unsubscribe(): void
  }

Source

Since v4.0.0