strev 0.5.0

Event-driven pub/sub messaging library with compile-time ack safety
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

use bytes::Bytes;
use strev::{Message, MessageStream};
use tokio_stream::StreamExt;

#[tokio::test]
async fn message_stream_receives_messages() {
    let (tx, stream) = MessageStream::channel(16);
    let msg = Message::new(Bytes::from("hello"));
    tx.send(msg).await.unwrap();
    drop(tx);

    let mut stream = stream;
    let received = stream.next().await.unwrap();
    assert_eq!(received.payload().as_ref(), b"hello");
    let _ = received.ack();
}

#[tokio::test]
async fn message_stream_returns_none_when_closed() {
    let (tx, stream) = MessageStream::channel(16);
    drop(tx);

    let mut stream = stream;
    assert!(stream.next().await.is_none());
}