connection-utils 0.8.0

Connection related utilities.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use anyhow::Result;
use async_trait::async_trait;
use tokio::sync::broadcast::Receiver;

use super::Channel;

pub type TOnRemoteChannelReader = Receiver<Box<dyn Channel>>;

#[async_trait]
pub trait Disconnected: Send {
    async fn connect(mut self: Box<Self>) -> Result<Box<dyn Connected>>;
    async fn accept_connection(mut self: Box<Self>) -> Result<Box<dyn Connected>>;
}

#[async_trait]
pub trait Connected: Send {
    fn on_remote_channel(&mut self) -> Result<TOnRemoteChannelReader>;
    fn off_remote_channel(&mut self, data: TOnRemoteChannelReader) -> Result<()>;

    async fn channel(&mut self, label: String, buffer_size: usize) -> Result<Box<dyn Channel>>;
    // async fn shutdown(mut self) -> Result<()>;
}