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
use bytes::Bytes;

use crate::{StatusCode, Subject, headers::HeaderMap, subscription_id::SubscriptionId};

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct MessageBase {
    pub subject: Subject,
    pub reply_subject: Option<Subject>,
    pub headers: HeaderMap,
    pub payload: Bytes,
}

#[derive(Debug, Clone, PartialEq, Eq)]
pub struct ServerMessage {
    pub status_code: Option<StatusCode>,
    pub subscription_id: SubscriptionId,
    pub base: MessageBase,
}