Struct TaskResponseReceiverWithConvert 

pub struct TaskResponseReceiverWithConvert<R, T>
where
    T: TryFrom<R>,
{ /* private fields */ }

Implementations

impl<R, T> TaskResponseReceiverWithConvert<R, T>

where R: Send + 'static, T: TryFrom<R, Error = Error> + Send + 'static,

pub fn create(receiver: Receiver<Result<R>>) -> Self

pub async fn try_recv(self) -> Result<T>

pub async fn process_on_recv<Fut>( self, process_callback: impl FnOnce(T) -> Fut + Send + 'static, )

where Fut: Future<Output = Result<()>> + Send,

Example:

let dispatcher = self.dispatcher.clone();
receiver.process_on_recv(|res| async move {
    dispatcher
       .enqueue_task(method_to_async_task_closure!(
            refresh_collation_sessions,
            res
        ))
        .await
});