Module connection 

Connection actor responsible for outbound frames.

The actor polls a shutdown token, high- and low-priority push queues, and an optional response stream using a tokio::select! loop. The biased keyword ensures high-priority messages are processed before low-priority ones, with streamed responses handled last.

Structs

ConnectionActor

Actor driving outbound frame delivery for a connection.

ConnectionChannels

Bundles push queues with their shared handle for actor construction.

FairnessConfig

Configuration controlling fairness when draining push queues.

Enums

ConnectionStateError

Error returned when attempting to set an active output source while another source is already active.

Functions

active_connection_count

Return the current number of active connections.