Struct TaggedMessage 

pub struct TaggedMessage {
    pub now: Instant,
    pub message: Message,
}

A Message together with the instant the caller is sending it at.

Rin is a TaggedBytesMut, which carries a timestamp; without this the write channel would not, and handle_write would have to ask the clock for one. A STUN client’s first action is typically a write before any read, so a retained instant is not an option here — it would still be the construction seed.

Fields

now: Instant

When the caller is sending this message.

message: Message

The STUN message to send.

Trait Implementations

impl Protocol<TransportMessage<BytesMut>, TaggedMessage, ()> for Client

fn poll_write(&mut self) -> Option<Self::Wout>

Returns packets to transmit

It should be polled for transmit after:

• the application performed some I/O
• a call was made to handle_read
• a call was made to handle_write
• a call was made to handle_timeout

type Rout = ()

Output read message type

type Wout = TransportMessage<BytesMut>

Output write message type

type Eout = StunEvent

Output event type

type Error = Error

Error type for protocol operations

type Time = Instant

Time/Instant type for timeout handling

fn handle_read(&mut self, msg: TaggedBytesMut) -> Result<()>

Handle an incoming read message.

fn poll_read(&mut self) -> Option<Self::Rout>

Poll for a processed read message.

fn handle_write(&mut self, msg: TaggedMessage) -> Result<()>

Handle an outgoing write message.

fn poll_event(&mut self) -> Option<Self::Eout>

Poll for a generated event.

fn poll_timeout(&mut self) -> Option<Self::Time>

Poll for the next timeout deadline.

fn handle_timeout(&mut self, now: Instant) -> Result<()>

Handle a timeout event.

fn close(&mut self) -> Result<()>

Close the protocol.

fn handle_event(&mut self, _evt: Ein) -> Result<(), Self::Error>

Handle a custom event.