centaurs 0.3.0

A utility crate.
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

#[async_trait::async_trait]
pub trait Consumer {
    type Output;
    type Error;

    async fn poll(&self) -> Result<Option<Self::Output>, Self::Error>;

    async fn commit(&self, message: Self::Output) -> Result<(), Self::Error>;

    fn subscribe(
        &self,
        topics: &[&str],
    ) -> Result<SubscribeGuard<Self::Output, Self::Error>, Self::Error>;

    fn unsubscribe(&self);

    fn auto_commit(&self) -> bool;
}

pub struct SubscribeGuard<'a, O, E> {
    pub consumer: &'a dyn Consumer<Output = O, Error = E>,
}

impl<'a, O, E> Drop for SubscribeGuard<'a, O, E> {
    fn drop(&mut self) {
        tracing::info!("unsubscribe");
        self.consumer.unsubscribe();
    }
}