Struct 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 = TransportMessage<BytesMut>

Read input message type.

type Rout = TransportMessage<String>

Read output message type.

type Win = TransportMessage<String>

Write input message type.

type Wout = TransportMessage<BytesMut>

Write output message type.

fn name(&self) -> &str

Returns the handler’s name.

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

Handles an inbound message.

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

Polls for an outbound message.

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

Called when the transport becomes active (connected).

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

Called when the transport becomes inactive (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 for the next timeout deadline.

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

Handles an end-of-file (EOF) event.

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

Handles an error event.

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

Handles a close event.