effect-io-ai

Package: effect
Module: PubSub

PubSub.dropping

Creates a bounded PubSub with the dropping strategy. The PubSub will drop new messages if the PubSub is at capacity.

For best performance use capacities that are powers of two.

Signature

declare const dropping: <A>(capacity: number | { readonly capacity: number; readonly replay?: number | undefined; }) => Effect.Effect<PubSub<A>>

Source

Since v2.0.0