Struct NackResponderInterceptor 

pub struct NackResponderInterceptor { /* private fields */ }

Interceptor that responds to NACK requests by retransmitting packets.

This interceptor buffers outgoing RTP packets on local streams and retransmits them when RTCP TransportLayerNack packets are received.

Trait Implementations

impl Interceptor for NackResponderInterceptor

fn bind_local_stream(&mut self, info: &StreamInfo)

bind_local_stream lets you modify any outgoing RTP packets. It is called once for per LocalStream. The returned method will be called once per rtp packet.

fn unbind_local_stream(&mut self, info: &StreamInfo)

unbind_local_stream is called when the Stream is removed. It can be used to clean up any data related to that track.

fn bind_remote_stream(&mut self, _info: &StreamInfo)

bind_remote_stream lets you modify any incoming RTP packets. It is called once for per RemoteStream. The returned method will be called once per rtp packet.

fn unbind_remote_stream(&mut self, _info: &StreamInfo)

unbind_remote_stream is called when the Stream is removed. It can be used to clean up any data related to that track.

impl Protocol<TransportMessage<AttributedPacket>, TransportMessage<AttributedPacket>, ()> for NackResponderInterceptor

type Rout = TransportMessage<AttributedPacket>

Output read message type

type Wout = TransportMessage<AttributedPacket>

Output write message type

type Eout = ()

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: TaggedPacket) -> Result<(), Self::Error>

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: TaggedPacket) -> Result<(), Self::Error>

Handle an outgoing write message.

fn poll_write(&mut self) -> Option<TaggedPacket>

Poll for a processed write message.

fn handle_timeout(&mut self, _now: Instant) -> Result<(), Self::Error>

Handle a timeout event.

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

Poll for the next timeout deadline.

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

Handle a custom event.

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

Poll for a generated event.

fn close(&mut self) -> Result<(), Self::Error>

Close the protocol.