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 Encoders errors to implement From<io::Error>in the interest of letting it return Errors 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.

Implementors

impl Encoder for BytesCodec

type Error = Error

impl Encoder for LengthDelimitedCodec

type Error = Error

impl Encoder for BytesCodec

type Error = Error

impl Encoder for AnyDelimiterCodecwhere T: AsRef,

type Error = AnyDelimiterCodecError

impl Encoder for LinesCodecwhere T: AsRef,

type Error = LinesCodecError