pub fn enqueue(&self, input: Input) -> Result<(), Input> {
        self.to_worker.try_send(input).map_err(|e| match e {
            TrySendError::Full(input) => input,
            TrySendError::Disconnected(_) => unreachable!("Worker channel disconnected"),
        })
    }
/// Try to enqueue a new input in the worker queue. Doesn't block. Will return the input if the queue is full.
Try to enqueue a new input in the worker queue. Doesn't block. Will return the input if the queue is full.
Try to enqueue a new input in the worker queue . Doesn ' t block . Will return the input if the queue is full .
pub fn enqueue(&self, input: Input) -> Result<(), Input> {
        self.to_worker.try_send(input).map_err(|e| match e {
            TrySendError::Full(input) => input,
            TrySendError::Disconnected(_) => unreachable!("Worker channel disconnected"),
        })
    }
pub fn enqueue ( & self , input : Input ) -> Result < ( ) , Input > { self . to_worker . try_send ( input ) . map_err ( | e | match e { TrySendError :: Full ( input ) => input , TrySendError :: Disconnected ( _ ) => unreachable ! ( " " ) , } ) }
Try to enqueue a new input in the worker queue.
Try to enqueue a new input in the worker queue .
&self
input
Input
&self
input
Input