Struct FrameFanout 

pub struct FrameFanout { /* private fields */ }

The pool’s fan-out: many subscribers, each with its own bounded queue.

Implementations

impl FrameFanout

pub fn new() -> Self

pub async fn subscribe(self: &Arc<Self>, capacity: usize) -> FrameSubscription

Open a subscription with room for capacity unread frames.

capacity is the consumer’s own promise about how far behind it may fall: beyond it the subscription is terminated rather than thinned.

pub async fn subscriber_count(&self) -> usize

How many subscriptions are still live.

pub fn allocate_session(&self, address: SocketAddr) -> FrameSource

Allocate the identity of a new session at address.

Allocation publishes nothing: a connection is identified before the pool decides whether to admit it, so a rejected duplicate cannot announce a session that never ran. open_session announces an admitted one.

pub async fn open_session(&self, source: FrameSource)

Announce that source has begun, before it can publish anything else.

The PoolFrame::Reset is delivered from INSIDE this call, so it is queued before any frame the session’s own task publishes. Publishing it from that task instead would make the ordering a race.

pub async fn publish(&self, source: FrameSource, frame: PoolFrame)

Deliver frame from source to every live subscriber, terminating any that has fallen behind.

A subscriber whose queue is FULL is removed, which drops the sender and ends its stream. A subscriber whose receiver is already gone is removed too; that one is ordinary tidying.

Trait Implementations

impl Default for FrameFanout

fn default() -> Self

Returns the “default value” for a type.