serviceless 0.5.0

An simple actor model in rust, like actix
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

use async_trait::async_trait;
use futures_core::Stream;

use crate::runtime::InnerOp;

pub trait UnboundedSender<T>: InnerOp + Clone + Send {
    type Error;

    fn send(&self, item: T) -> Result<(), Self::Error>;

    fn is_closed(&self) -> bool;
}

#[async_trait]
pub trait UnboundedReceiver<T>: InnerOp + Stream<Item = T> + Unpin + Send {
    type Error;

    async fn recv(&mut self) -> Result<T, Self::Error>;

    fn close(&mut self);

    fn len(&self) -> usize;

    fn is_empty(&self) -> bool {
        self.len() == 0
    }
}