Struct TaskResponseReceiver 

pub struct TaskResponseReceiver<R> { /* private fields */ }

Implementations

impl<R> TaskResponseReceiver<R>

where R: Send + 'static,

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

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

pub async fn process_on_recv<Fut>( self, process_callback: impl FnOnce(R) -> 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
});