effect-io-ai

Package: effect
Module: TPubSub

TPubSub.bounded

Creates a bounded TPubSub with the back pressure strategy. The TPubSub will retain messages until they have been taken by all subscribers, applying back pressure to publishers if the TPubSub is at capacity.

Signature

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

Source

Since v2.0.0