Expand description
§JetStream Rpc
Defines Rpc primitives for JetStream.
Of note is the Protocol trait which is meant to be used with the service attribute macro.
Re-exports§
pub use framer::*;
Modules§
Structs§
- Framed
- A unified
StreamandSinkinterface to an underlying I/O object, using theEncoderandDecodertraits to encode and decode frames. - Tag
Enums§
Constants§
Traits§
- Decoder
- Decoding of frames via buffers.
- Dynamic
Protocol - Encoder
- Trait of helper objects to write out messages as bytes, for use with
FramedWrite. - Into
Error - IntoError trait allows conversion of various error types into Jetstream Error.
- Message
- A trait representing a message that can be encoded and decoded.
- Protocol
- Defines the request and response types for the JetStream protocol.