muxio 0.10.2-alpha

Toolkit for layered stream multiplexing and schemaless 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
25
26
27
28
29

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

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