muxio 0.3.0-alpha

Toolkit for layered stream multiplexing and schema-less RPC communication
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

use crate::{frame::FrameDecodeError, rpc::rpc_internals::RpcHeader};

#[derive(Debug, Clone)]
pub enum RpcStreamEvent {
    Header {
        rpc_header_id: u32,
        rpc_method_id: u64,
        rpc_header: RpcHeader,
    },
    PayloadChunk {
        rpc_header_id: u32,
        rpc_method_id: u64,
        bytes: Vec<u8>,
    },
    End {
        rpc_header_id: u32,
        rpc_method_id: u64,
    },
    Error {
        rpc_header_id: Option<u32>,
        rpc_method_id: Option<u64>,
        frame_decode_error: FrameDecodeError,
    },
}