Struct DataChannelHandler

pub struct DataChannelHandler { /* private fields */ }

DataChannelHandler implements DataChannel Protocol handling

Implementations

impl DataChannelHandler

pub fn new() -> Self

Trait Implementations

impl Default for DataChannelHandler

fn default() -> DataChannelHandler

Returns the “default value” for a type.

impl Handler for DataChannelHandler

type Rin = TaggedMessageEvent

Associated input message type for [InboundHandler::read]

type Rout = <DataChannelHandler as Handler>::Rin

Associated output message type for [InboundHandler::read]

type Win = TaggedMessageEvent

Associated input message type for [OutboundHandler::write]

type Wout = <DataChannelHandler as Handler>::Win

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.