jetstream_rpc
Trait Encoder
pub trait Encoder<Item> {
type Error: From<Error>;
// Required method
fn encode(
&mut self,
item: Item,
dst: &mut BytesMut,
) -> Result<(), Self::Error>;
}
Trait of helper objects to write out messages as bytes, for use with FramedWrite
.
Required Associated Types
type Error: From
The type of encoding errors.
FramedWrite
requires Encoder
s errors to implement From<io::Error>
in the interest of letting it return Error
s directly.
Required Methods
fn encode(&mut self, item: Item, dst: &mut BytesMut) -> Result<(), Self::Error>
Encodes a frame into the buffer provided.
This method will encode item
into the byte buffer provided by dst
. The dst
provided is an internal buffer of the FramedWrite
instance and will be written out when possible.