pub async fn requeue_at(&self, obj: T, time: Instant) -> Result<(), SendError<T>> {
        self.tx
            .send(Op::Requeue(obj, time))
            .await
            .map_err(|SendError(op)| match op {
                Op::Requeue(obj, _) => SendError(obj),
                _ => unreachable!(),
            })
    }
/// Schedule the given object to be rescheduled at the given time.
Schedule the given object to be rescheduled at the given time.
Schedule the given object to be rescheduled at the given time .
pub async fn requeue_at(&self, obj: T, time: Instant) -> Result<(), SendError<T>> {
        self.tx
            .send(Op::Requeue(obj, time))
            .await
            .map_err(|SendError(op)| match op {
                Op::Requeue(obj, _) => SendError(obj),
                _ => unreachable!(),
            })
    }
pub async fn requeue_at ( & self , obj : T , time : Instant ) -> Result < ( ) , SendError < T > > { self . tx . send ( Op :: Requeue ( obj , time ) ) . await . map_err ( | SendError ( op ) | match op { Op :: Requeue ( obj , _ ) => SendError ( obj ) , _ => unreachable ! ( ) , } ) }
Schedule the given object to be rescheduled at the given time.
Schedule the given object to be rescheduled at the given time .
&self
obj
T
time
Instant
&self
obj
T
time
Instant