eventful 0.2.1

A library for event sourcing in Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34

//! This is an implementation of the ask pattern that uses a [tokio::sync::oneshot] channel internally to convey the reply.

use anyhow::anyhow;
use std::fmt::Debug;
use tokio::sync::oneshot;

#[derive(Debug)]
pub struct ReplyTo<T> {
    sender: oneshot::Sender<T>,
}

impl<T> ReplyTo<T> {
    pub fn new() -> (oneshot::Receiver<T>, Self) {
        let (tx, rx) = oneshot::channel();
        let ask_reply = Self { sender: tx };
        (rx, ask_reply)
    }
}

pub trait ReplyWith<T> {
    fn reply_with(self, reply: T) -> anyhow::Result<()>;
}

impl<T> ReplyWith<T> for ReplyTo<T> {
    fn reply_with(self, reply: T) -> anyhow::Result<()> {
        match self.sender.send(reply) {
            Ok(_) => Ok(()),
            Err(_) => {
                tracing::error!("Error sending reply");
                Err(anyhow!("Error sending reply"))
            }
        }
    }
}