effect-io-ai

Package: effect
Module: TPubSub

TPubSub.dropping

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

Signature

declare const dropping: <A>(requestedCapacity: number) => STM.STM<TPubSub<A>>

Source

Since v2.0.0