Struct Rfc8888Interceptor 

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

Reports when each packet of each bound remote stream arrived (RFC 8888).

Differences from upstream

pion/interceptor injects a SenderTicker and a SenderNow so its tests can control time. Sans-I/O needs neither: every instant arrives as a parameter, so the tests drive the clock by passing one. Both are dropped.

Upstream’s Recorder also never sets its sender SSRC, so every report it builds claims to come from SSRC 0. Here it is configured.

Trait Implementations

impl<P: Interceptor> Interceptor for Rfc8888Interceptor<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 Self: Sized, F: FnOnce(Self) -> O, O: Interceptor,

Wrap this interceptor with another layer.

impl<P: Interceptor> Protocol<TransportMessage<Packet>, TransportMessage<Packet>, ()> for Rfc8888Interceptor<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 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 handle_event(&mut self, evt: ()) -> 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.

fn handle_read(&mut self, msg: TaggedPacket) -> Result<(), Self::Error>

Handle an incoming read 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 poll_write(&mut self) -> Option<Self::Wout>

Poll for a processed write message.