Struct Codec

pub struct Codec<Req, Resp> { /* private fields */ }

Available on crate feature json only.

Implementations

impl<Req, Resp> Codec<Req, Resp>

pub fn set_request_size_maximum(self, request_size_maximum: u64) -> Self

Sets the limit for request size in bytes.

pub fn set_response_size_maximum(self, response_size_maximum: u64) -> Self

Sets the limit for response size in bytes.

Trait Implementations

impl<Req, Resp> Clone for Codec<Req, Resp>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<Req, Resp> Codec for Codec<Req, Resp>

where Req: Send + Serialize + DeserializeOwned, Resp: Send + Serialize + DeserializeOwned,

type Protocol = StreamProtocol

The type of protocol(s) or protocol versions being negotiated.

type Request = Req

The type of inbound and outbound requests.

type Response = Resp

The type of inbound and outbound responses.

fn read_request<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 mut self, _: &'life1 Self::Protocol, io: &'life2 mut T, ) -> Pin<Box<dyn Future<Output = Result<Req>> + Send + 'async_trait>>

where T: AsyncRead + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Reads a request from the given I/O stream according to the negotiated protocol.

fn read_response<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 mut self, _: &'life1 Self::Protocol, io: &'life2 mut T, ) -> Pin<Box<dyn Future<Output = Result<Resp>> + Send + 'async_trait>>

where T: AsyncRead + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Reads a response from the given I/O stream according to the negotiated protocol.

fn write_request<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 mut self, _: &'life1 Self::Protocol, io: &'life2 mut T, req: Self::Request, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where T: AsyncWrite + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Writes a request to the given I/O stream according to the negotiated protocol.

fn write_response<'life0, 'life1, 'life2, 'async_trait, T>( &'life0 mut self, _: &'life1 Self::Protocol, io: &'life2 mut T, resp: Self::Response, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where T: AsyncWrite + Unpin + Send + 'async_trait, Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Writes a response to the given I/O stream according to the negotiated protocol.

impl<Req, Resp> Default for Codec<Req, Resp>

fn default() -> Self

Returns the “default value” for a type.