Struct NoopInterceptor 

pub struct NoopInterceptor { /* private fields */ }

A no-operation interceptor that simply queues messages for pass-through.

NoopInterceptor serves as the innermost layer of an interceptor chain. It accepts messages via handle_read/handle_write/etc and returns them unchanged via poll_read/poll_write/etc.

Example

use rtc_interceptor::NoopInterceptor;
use sansio::Protocol;

let mut noop = NoopInterceptor::new();
noop.handle_read(TaggedPacket::Rtp(...)).unwrap();
assert!(noop.poll_read().is_some());

Implementations

impl NoopInterceptor

pub fn new() -> Self

Create a new NoopInterceptor.

Trait Implementations

impl Default for NoopInterceptor

fn default() -> Self

Returns the “default value” for a type.

impl Interceptor for NoopInterceptor

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 Protocol<TransportMessage<Packet>, TransportMessage<Packet>, ()> for NoopInterceptor

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_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 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 close(&mut self) -> Result<(), Self::Error>

Close the protocol.