watermelon 0.4.4

High level actor based implementation NATS Core and NATS Jetstream client implementation
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
28

use std::{collections::BTreeSet, sync::Arc};

use arc_swap::ArcSwapOption;
use tokio::sync::mpsc;
use watermelon_proto::{ServerInfo, Subject};

use crate::{
    client::{RawQuickInfo, create_inbox_subject},
    handler::HandlerCommand,
};

#[derive(Debug)]
pub(crate) struct TestHandler {
    pub(crate) receiver: mpsc::Receiver<HandlerCommand>,
    pub(crate) _info: Arc<ArcSwapOption<ServerInfo>>,
    pub(crate) quick_info: Arc<RawQuickInfo>,
}

#[test]
fn unique_create_inbox_subject() {
    const ITERATIONS: usize = if cfg!(miri) { 100 } else { 100_000 };

    let prefix = Subject::from_static("abcd");
    let subjects = (0..ITERATIONS)
        .map(|_| create_inbox_subject(&prefix))
        .collect::<BTreeSet<_>>();
    assert_eq!(subjects.len(), ITERATIONS);
}