Struct NackGeneratorInterceptor 

pub struct NackGeneratorInterceptor<P> { /* private fields */ }

Interceptor that generates NACK requests for missing RTP packets.

This interceptor monitors incoming RTP packets on remote streams, tracks which sequence numbers have been received, and periodically generates RTCP TransportLayerNack packets for missing sequences.

Trait Implementations

impl<P: Interceptor> Interceptor for NackGeneratorInterceptor<P>

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.

fn with<O, F>(self, f: F) -> O

where F: FnOnce(Self) -> O, O: Interceptor,

Wrap this interceptor with another layer.

impl<P: Interceptor> Protocol<TransportMessage<Packet>, TransportMessage<Packet>, ()> for NackGeneratorInterceptor<P>

type Rout = TransportMessage<Packet>

Output read message type

type Wout = TransportMessage<Packet>

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<Self::Wout>

Poll for a processed write message.

fn handle_timeout(&mut self, now: Self::Time) -> 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.