Skip to main content

handle_connection

Function handle_connection 

Source
pub async fn handle_connection<S>(state: Arc<DaemonState>, stream: S)
where S: AsyncRead + AsyncWrite + Unpin + Send,
Expand description

Handle a single client connection. Reads exactly one Request, then either replies with a single Response and closes (control RPCs), or streams Events filtered by job id (job submissions, Subscribe, Attach) until terminated by JobFinished or a shutdown signal.