acril 0.1.0

A kitchen-sink actor framework.
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_tungstenite::{tungstenite::Message, WebSocketStream};
use futures::{Sink, SinkExt, StreamExt, io::{AsyncRead, AsyncWrite}};

use crate::{Handler, Service};

pub async fn lifecycle<
    S: AsyncRead + AsyncWrite + Unpin + Send + 'static,
    H: Service<Context = WebSocketStream<S>>,
>(
    mut stream: WebSocketStream<S>,
    mut handler: H,
) -> Result<(), H::Error>
where
    H::Error: From<async_tungstenite::tungstenite::Error>
        + From<<WebSocketStream<S> as Sink<Message>>::Error>
        + Send
        + 'static,
    H: Handler<Message, call(): Send> + Send + 'static,
    H::Response: Into<Message>,
{
    while let Some(item) = stream.next().await {
        let response = handler.call(item?, &mut stream).await?;
        stream.send(response.into()).await?;
    }

    Ok(())
}