watermelon-proto 0.1.8

#[no_std] NATS Core Sans-IO protocol 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 alloc::boxed::Box;
use core::num::NonZero;

use crate::{
    Subject, connect::Connect, message::MessageBase, queue_group::QueueGroup,
    subscription_id::SubscriptionId,
};

#[derive(Debug)]
pub enum ClientOp {
    Connect {
        connect: Box<Connect>,
    },
    Publish {
        message: MessageBase,
    },
    Subscribe {
        id: SubscriptionId,
        subject: Subject,
        queue_group: Option<QueueGroup>,
    },
    Unsubscribe {
        id: SubscriptionId,
        max_messages: Option<NonZero<u64>>,
    },
    Ping,
    Pong,
}