myelin 0.1.0

Define async service APIs as traits, communicate over channels. Transport and serialization are pluggable.
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
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45

//! Layered stream transport: Framing × Encoding × ReplyRouting.
//!
//! This module decomposes the monolithic postcard-over-stream transport
//! into three composable layers:
//!
//! - **Framing** ([`framing`]) — how bytes are chunked on the wire.
//! - **Encoding** ([`codec`]) — how types become bytes.
//! - **Reply routing** ([`routing`]) — how responses are matched to callers.
//!
//! The layers are composed into a single [`StreamTransport`] that implements
//! [`ClientTransport`](crate::transport::ClientTransport) and
//! [`ServerTransport`](crate::transport::ServerTransport).
//!
//! ## Routing strategies
//!
//! - [`Sequential`] — one request at a time, zero overhead.
//! - [`MuxedSlots`] — up to N concurrent requests via slot-based routing
//!   (1-byte slot ID per frame).

pub mod codec;
pub mod duplex;
pub mod framing;
pub mod mux;
pub mod routing;
pub mod transport;

#[cfg(feature = "cbor")]
pub use codec::CborCodec;
#[cfg(feature = "cbor")]
pub use codec::CborCodecError;
#[cfg(feature = "postcard")]
pub use codec::PostcardCodec;
pub use codec::{Decoder, Encoder};
pub use duplex::{
    DUPLEX_HEADER_LEN, DuplexClientHalf, DuplexFrameError, DuplexHandle, DuplexHeader, DuplexPump,
    DuplexPumpError, DuplexServerError, DuplexServerHalf, DuplexStreamTransport, KIND_REQUEST,
    KIND_RESPONSE, encode_duplex_frame, parse_duplex_frame,
};
pub use framing::{FrameReader, FrameWriter, FramingError, LengthPrefixed};
pub use mux::{ApiHandler, ApiRouter, MuxError, ServiceApiId};
pub use routing::{
    MuxedReplyToken, MuxedSlotGuard, MuxedSlots, MuxedSlots4, MuxedSlots8, ReplyRouter,
    RouterSlotHandle, Sequential,
};
pub use transport::{RouterStorage, StreamReplyToken, StreamTransport, StreamTransportError};