diath 0.5.1

diath is a light-weight library for communication between tokio async tasks
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::enquiry::dialogue::Dialogue;
use tokio::sync::mpsc;

/// Responder can Listen questions, when a question is asked a new `Dialogue` is created
/// Instances are created by the [`enquiry::new(size)`](crate::enquiry::new()) function
pub struct Responder<Q, A> {
    question_receiver: mpsc::Receiver<Dialogue<Q, A>>,
}

impl<Q, A> Responder<Q, A> {
    /// Creates a new Responder
    pub(super) fn new(question_receiver: mpsc::Receiver<Dialogue<Q, A>>) -> Self {
        Self {
            question_receiver
        }
    }
    /// Listen until a question is asked
    pub async fn listen(&mut self) -> Option<Dialogue<Q, A>> {
        self.question_receiver.recv().await
    }
}