nstreams-core 0.3.0

Generic versioned event stream handler with history replay
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

use crate::event::DeliveredEvent;

/// Client-facing subscription delivering versioned events for a single request.
pub struct Subscription {
    request_id: String,
    rx: tokio::sync::mpsc::Receiver<crate::Result<DeliveredEvent>>,
}

impl Subscription {
    pub(crate) fn new(
        request_id: String,
        rx: tokio::sync::mpsc::Receiver<crate::Result<DeliveredEvent>>,
    ) -> Self {
        Self { request_id, rx }
    }

    pub fn request_id(&self) -> &str {
        &self.request_id
    }

    pub async fn next(&mut self) -> Option<crate::Result<DeliveredEvent>> {
        self.rx.recv().await
    }

    pub fn into_parts(
        self,
    ) -> (
        String,
        tokio::sync::mpsc::Receiver<crate::Result<DeliveredEvent>>,
    ) {
        (self.request_id, self.rx)
    }
}