pub(crate) async fn send(self, req: Request) -> anyhow::Result<WorkerResponses<'a>> {
        self.worker.state.store(WorkerStateKind::Judge);
        self.worker
            .send(req)
            .await
            .map_err(|err| {
                tracing::warn!("request not delivered, marking worker as crashed");
                self.worker.state.store(WorkerStateKind::Crash);
                err
            })
            .context("failed to send request")?;
        Ok(WorkerResponses { handle: Some(self) })
    }
/// Sends request to worker, returning "stream" of responses
Sends request to worker, returning "stream" of responses
Sends request to worker returning " stream " of responses
pub(crate) async fn send(self, req: Request) -> anyhow::Result<WorkerResponses<'a>> {
        self.worker.state.store(WorkerStateKind::Judge);
        self.worker
            .send(req)
            .await
            .map_err(|err| {
                tracing::warn!("request not delivered, marking worker as crashed");
                self.worker.state.store(WorkerStateKind::Crash);
                err
            })
            .context("failed to send request")?;
        Ok(WorkerResponses { handle: Some(self) })
    }
pub ( crate ) async fn send ( self , req : Request ) -> anyhow :: Result < WorkerResponses < ' a > > { self . worker . state . store ( WorkerStateKind :: Judge ) ; self . worker . send ( req ) . await . map_err ( | err | { tracing :: warn ! ( " " ) ; self . worker . state . store ( WorkerStateKind :: Crash ) ; err } ) . context ( " " ) ? ; Ok ( WorkerResponses { handle : Some ( self ) } ) }
Sends request to worker, returning "stream" of responses
Sends request to worker returning " stream " of responses
self
req
Request