effect-io-ai

Package: effect
Module: TPubSub

TPubSub.sliding

Creates a bounded TPubSub with the sliding strategy. The TPubSub will add new messages and drop old messages if the TPubSub is at capacity.

For best performance use capacities that are powers of two.

Signature

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

Source

Since v2.0.0