pub trait StreamRefPayload: Send + 'static {
// Required methods
fn encode_stream_ref_payload(self) -> Vec<u8> ⓘ;
fn decode_stream_ref_payload(bytes: Vec<u8>) -> StreamResult<Self>
where Self: Sized;
}Expand description
Element payload codec used by the protobuf StreamRefs transport seam.
The built-in impls use the same big-endian primitive encodings as Ractor’s
BytesConvertable, but the trait is owned by datum-core so the protobuf
seam does not depend on the cluster feature.
Required Methods§
fn encode_stream_ref_payload(self) -> Vec<u8> ⓘ
fn decode_stream_ref_payload(bytes: Vec<u8>) -> StreamResult<Self>where
Self: Sized,
Dyn Compatibility§
This trait is dyn compatible.
In older versions of Rust, dyn compatibility was called "object safety".