Skip to main content

run_reader

agentmux_srv::backend::blockcontroller::app_server

Function run_reader 

Source 
async fn run_reader<R>(
    reader: R,
    incoming_tx: Sender<AppServerIncoming>,
    shared: Arc<SharedState>,
    max_frame_bytes: usize,
)
where
    R: AsyncRead + Unpin,