Struct Manager 

pub struct Manager { /* private fields */ }

Actor that owns all incoming-stream state and processes InputEvents on a single task (see Self::run). Because it owns its state directly (no shared Mutex), its handlers can .await decompression on the run-loop task.

Implementations

impl Manager

pub fn new( max_payload_byte_length: Option<usize>, ) -> (Self, ManagerInput, UnboundedReceiver<OutputEvent>)

pub async fn run(self)

Runs the manager’s event loop until the input channel closes (all ManagerInputs dropped) or InputEvent::Shutdown is received. On exit, dropping self closes every open reader.