Struct retty::codec::string_codec::TaggedStringCodec

pub struct TaggedStringCodec;

A tagged StringCodec handler that reads with input of TaggedBytesMut and output of TaggedString, or writes with input of TaggedString and output of TaggedBytesMut

Implementations

impl TaggedStringCodec

pub fn new() -> Self

Creates a new TaggedStringCodec handler

Trait Implementations

impl Default for TaggedStringCodec

fn default() -> Self

Returns the “default value” for a type.

impl Handler for TaggedStringCodec

type Rin = TaggedBytesMut

Associated input message type for [InboundHandler::read]

type Rout = TaggedString

Associated output message type for [InboundHandler::read]

type Win = TaggedString

Associated input message type for [OutboundHandler::write]

type Wout = TaggedBytesMut

Associated output message type for [OutboundHandler::write]

fn name(&self) -> &str

Returns handler name

fn handle_read( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout>, msg: Self::Rin )

Handles input message.

fn poll_write( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout> ) -> Option<Self::Wout>

Polls output message from internal transmit queue

fn transport_active( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout> )

Transport is active now, which means it is connected.

fn transport_inactive( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout> )

Transport is inactive now, which means it is disconnected.

fn handle_timeout( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout>, now: Instant )

Handles a timeout event.

fn poll_timeout( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout>, eto: &mut Instant )

Polls earliest timeout (eto) in its inbound operations.

fn handle_read_eof( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout> )

Reads an EOF event.

fn handle_exception( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout>, err: Box<dyn Error> )

Handle an Error exception in one of its operations.

fn handle_close( &mut self, ctx: &Context<Self::Rin, Self::Rout, Self::Win, Self::Wout> )

Handle a close event.