Skip to main content

forward_queued

forge_server::transport::connection

Function forward_queued 

Source 
fn forward_queued(
    state: &TransportState,
    frames: Vec<SeatUpdate>,
    watched: &[Subject],
    me: u64,
) -> Vec<SeatUpdate>
Expand description

The frames a subscribe read out of the stream it replaced: filtered for this connection, and bounded like every other path to a client (#2374).