openlimits-messaging 0.1.0

The messaging system of OpenLimits.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

use async_trait::async_trait;

use std::pin::Pin;
use futures::stream::Stream;

pub type Subscription<T> = Pin<Box<dyn Stream<Item = T>>>;

#[async_trait]
pub trait Subscriber {
    type SubscriptionRequest;
    type Publication;
    type Error;
    async fn subscribe(&mut self, subscription: &Self::SubscriptionRequest) -> Result<Subscription<Self::Publication>, Self::Error>;
}