pub async fn encode<M>(&mut self, msg: M) -> io::Result<()>
    where
        M: Encodable + Send + Sync,
    {
        self.inner.encode(msg).await?;
        if self.activity_tx.send(()).await.is_err() {
            return Err(std::io::Error::new(
                std::io::ErrorKind::UnexpectedEof,
                "Runner has closed its receiver",
            ));
        }
        Ok(())
    }
/// Encode this [Encodable] message to the writer.
Encode this [Encodable] message to the writer.
Encode this [ Encodable ] message to the writer .
pub async fn encode<M>(&mut self, msg: M) -> io::Result<()>
    where
        M: Encodable + Send + Sync,
    {
        self.inner.encode(msg).await?;
        if self.activity_tx.send(()).await.is_err() {
            return Err(std::io::Error::new(
                std::io::ErrorKind::UnexpectedEof,
                "Runner has closed its receiver",
            ));
        }
        Ok(())
    }
pub async fn encode < M > ( & mut self , msg : M ) -> io :: Result < ( ) > where M : Encodable + Send + Sync , { self . inner . encode ( msg ) . await ? ; if self . activity_tx . send ( ( ) ) . await . is_err ( ) { return Err ( std :: io :: Error :: new ( std :: io :: ErrorKind :: UnexpectedEof , " " , ) ) ; } Ok ( ( ) ) }
Encode this [Encodable] message to the writer.
Encode this [ Encodable ] message to the writer .
&mut self
msg
M
&mut self
msg
M