pub mod tst_pipeline
pub use tst_pipeline::RecvTransport
pub use tst_pipeline::SrtCancelHandle
pub use tst_pipeline::Transport
pub use tst_pipeline::TransportCancel
pub use tst_pipeline::TransportError
pub mod tst_pipeline::demux_receiver
#[non_exhaustive] pub enum tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub tst_pipeline::demux_receiver::DemuxReceiverErrorSource::Demux(tst_core::error::DemuxError)
pub tst_pipeline::demux_receiver::DemuxReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub struct tst_pipeline::demux_receiver::DemuxReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::add_byte_sink(&mut self, tst_pipeline::demux_receiver::ByteSink)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::new(R) -> Self
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::recv_event(&mut self) -> core::result::Result<core::option::Option<tst_core::mpegts::demux::event::DemuxEvent>, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::with_demux_options(R, tst_core::mpegts::demux::types::DemuxerConfig) -> Self
impl<R: tst_core::transport::RecvTransport> tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::stats(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::iter::traits::iterator::Iterator for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Item = core::result::Result<tst_core::mpegts::demux::event::DemuxEvent, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::next(&mut self) -> core::option::Option<Self::Item>
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> !core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiver<R>
#[non_exhaustive] pub struct tst_pipeline::demux_receiver::DemuxReceiverError
pub tst_pipeline::demux_receiver::DemuxReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::demux_receiver::DemuxReceiverError::source: tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverError
pub struct tst_pipeline::demux_receiver::DemuxReceiverStats
pub tst_pipeline::demux_receiver::DemuxReceiverStats::bytes_received: u64
pub tst_pipeline::demux_receiver::DemuxReceiverStats::discontinuities: u64
pub tst_pipeline::demux_receiver::DemuxReceiverStats::nonconformant: u64
pub tst_pipeline::demux_receiver::DemuxReceiverStats::packets_received: u64
pub tst_pipeline::demux_receiver::DemuxReceiverStats::per_stream: alloc::collections::btree::map::BTreeMap<u16, tst_core::mpegts::stats::StreamStats>
pub tst_pipeline::demux_receiver::DemuxReceiverStats::pmt_versions_seen: u64
pub tst_pipeline::demux_receiver::DemuxReceiverStats::program_maps_seen: u64
impl core::clone::Clone for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::clone(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::cmp::Eq for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::cmp::PartialEq for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::eq(&self, &tst_pipeline::demux_receiver::DemuxReceiverStats) -> bool
impl core::default::Default for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::default() -> tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverStats
pub type tst_pipeline::demux_receiver::BoxedDemuxReceiver = tst_pipeline::demux_receiver::DemuxReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::demux_receiver::ByteSink = alloc::boxed::Box<(dyn core::ops::function::FnMut(&[u8]) + core::marker::Send)>
pub mod tst_pipeline::dyn_aliases
pub type tst_pipeline::dyn_aliases::BoxedDemuxReceiver = tst_pipeline::demux_receiver::DemuxReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::dyn_aliases::BoxedMuxSender = tst_pipeline::mux_sender::MuxSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub type tst_pipeline::dyn_aliases::BoxedRawReceiver = tst_pipeline::raw_receiver::RawReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::dyn_aliases::BoxedRawSender = tst_pipeline::raw_sender::RawSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub type tst_pipeline::dyn_aliases::BoxedReceiver = tst_pipeline::receiver::Receiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::dyn_aliases::BoxedSender = tst_pipeline::sender::Sender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub mod tst_pipeline::ext
pub mod tst_pipeline::ext::pairing
#[non_exhaustive] pub enum tst_pipeline::ext::pairing::PairerMode
pub tst_pipeline::ext::pairing::PairerMode::Buffered
pub tst_pipeline::ext::pairing::PairerMode::Buffered::max_lag: core::time::Duration
pub tst_pipeline::ext::pairing::PairerMode::Realtime
impl core::clone::Clone for tst_pipeline::ext::pairing::PairerMode
pub fn tst_pipeline::ext::pairing::PairerMode::clone(&self) -> tst_pipeline::ext::pairing::PairerMode
impl core::cmp::Eq for tst_pipeline::ext::pairing::PairerMode
impl core::cmp::PartialEq for tst_pipeline::ext::pairing::PairerMode
pub fn tst_pipeline::ext::pairing::PairerMode::eq(&self, &tst_pipeline::ext::pairing::PairerMode) -> bool
impl core::fmt::Debug for tst_pipeline::ext::pairing::PairerMode
pub fn tst_pipeline::ext::pairing::PairerMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::ext::pairing::PairerMode
impl core::marker::StructuralPartialEq for tst_pipeline::ext::pairing::PairerMode
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairerMode
impl core::marker::Send for tst_pipeline::ext::pairing::PairerMode
impl core::marker::Sync for tst_pipeline::ext::pairing::PairerMode
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairerMode
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairerMode
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairerMode
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairerMode
pub enum tst_pipeline::ext::pairing::PairerOutput
pub tst_pipeline::ext::pairing::PairerOutput::Paired
pub tst_pipeline::ext::pairing::PairerOutput::Paired::klv: tst_pipeline::ext::pairing::KlvSample
pub tst_pipeline::ext::pairing::PairerOutput::Paired::video: tst_pipeline::ext::pairing::VideoSample
pub tst_pipeline::ext::pairing::PairerOutput::PassThrough(tst_core::mpegts::demux::event::DemuxEvent)
pub tst_pipeline::ext::pairing::PairerOutput::UnpairedKlv(tst_pipeline::ext::pairing::KlvSample)
pub tst_pipeline::ext::pairing::PairerOutput::UnpairedVideo(tst_pipeline::ext::pairing::VideoSample)
impl core::clone::Clone for tst_pipeline::ext::pairing::PairerOutput
pub fn tst_pipeline::ext::pairing::PairerOutput::clone(&self) -> tst_pipeline::ext::pairing::PairerOutput
impl core::cmp::Eq for tst_pipeline::ext::pairing::PairerOutput
impl core::cmp::PartialEq for tst_pipeline::ext::pairing::PairerOutput
pub fn tst_pipeline::ext::pairing::PairerOutput::eq(&self, &tst_pipeline::ext::pairing::PairerOutput) -> bool
impl core::fmt::Debug for tst_pipeline::ext::pairing::PairerOutput
pub fn tst_pipeline::ext::pairing::PairerOutput::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::ext::pairing::PairerOutput
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairerOutput
impl core::marker::Send for tst_pipeline::ext::pairing::PairerOutput
impl core::marker::Sync for tst_pipeline::ext::pairing::PairerOutput
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairerOutput
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairerOutput
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairerOutput
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairerOutput
pub struct tst_pipeline::ext::pairing::KlvSample
pub tst_pipeline::ext::pairing::KlvSample::kind: tst_core::mpegts::demux::event::MetadataKind
pub tst_pipeline::ext::pairing::KlvSample::payload: alloc::vec::Vec<u8>
pub tst_pipeline::ext::pairing::KlvSample::pts: tst_core::mpegts::common::Pts90khz
pub tst_pipeline::ext::pairing::KlvSample::stream: tst_core::mpegts::demux::event::StreamId
impl core::clone::Clone for tst_pipeline::ext::pairing::KlvSample
pub fn tst_pipeline::ext::pairing::KlvSample::clone(&self) -> tst_pipeline::ext::pairing::KlvSample
impl core::cmp::Eq for tst_pipeline::ext::pairing::KlvSample
impl core::cmp::PartialEq for tst_pipeline::ext::pairing::KlvSample
pub fn tst_pipeline::ext::pairing::KlvSample::eq(&self, &tst_pipeline::ext::pairing::KlvSample) -> bool
impl core::fmt::Debug for tst_pipeline::ext::pairing::KlvSample
pub fn tst_pipeline::ext::pairing::KlvSample::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::ext::pairing::KlvSample
impl core::marker::Freeze for tst_pipeline::ext::pairing::KlvSample
impl core::marker::Send for tst_pipeline::ext::pairing::KlvSample
impl core::marker::Sync for tst_pipeline::ext::pairing::KlvSample
impl core::marker::Unpin for tst_pipeline::ext::pairing::KlvSample
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::KlvSample
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::KlvSample
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::KlvSample
pub struct tst_pipeline::ext::pairing::Pairer
impl tst_pipeline::ext::pairing::Pairer
pub fn tst_pipeline::ext::pairing::Pairer::feed(&mut self, tst_core::mpegts::demux::event::DemuxEvent) -> alloc::vec::Vec<tst_pipeline::ext::pairing::PairerOutput>
pub fn tst_pipeline::ext::pairing::Pairer::flush(&mut self) -> alloc::vec::Vec<tst_pipeline::ext::pairing::PairerOutput>
pub fn tst_pipeline::ext::pairing::Pairer::last_before_pts(u16, u16, core::option::Option<core::time::Duration>) -> Self
pub fn tst_pipeline::ext::pairing::Pairer::new(u16, u16) -> Self
pub fn tst_pipeline::ext::pairing::Pairer::reset_stats(&mut self)
pub fn tst_pipeline::ext::pairing::Pairer::stats(&self) -> tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::Pairer::with_config(u16, u16, tst_pipeline::ext::pairing::PairerConfig) -> Self
impl core::marker::Freeze for tst_pipeline::ext::pairing::Pairer
impl core::marker::Send for tst_pipeline::ext::pairing::Pairer
impl core::marker::Sync for tst_pipeline::ext::pairing::Pairer
impl core::marker::Unpin for tst_pipeline::ext::pairing::Pairer
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::Pairer
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::Pairer
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::Pairer
#[non_exhaustive] pub struct tst_pipeline::ext::pairing::PairerConfig
pub tst_pipeline::ext::pairing::PairerConfig::link_klv_to_video: bool
pub tst_pipeline::ext::pairing::PairerConfig::max_buffered_klv: u64
pub tst_pipeline::ext::pairing::PairerConfig::max_buffered_video: u64
pub tst_pipeline::ext::pairing::PairerConfig::mode: tst_pipeline::ext::pairing::PairerMode
pub tst_pipeline::ext::pairing::PairerConfig::tolerance: core::time::Duration
impl core::clone::Clone for tst_pipeline::ext::pairing::PairerConfig
pub fn tst_pipeline::ext::pairing::PairerConfig::clone(&self) -> tst_pipeline::ext::pairing::PairerConfig
impl core::default::Default for tst_pipeline::ext::pairing::PairerConfig
pub fn tst_pipeline::ext::pairing::PairerConfig::default() -> Self
impl core::fmt::Debug for tst_pipeline::ext::pairing::PairerConfig
pub fn tst_pipeline::ext::pairing::PairerConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairerConfig
impl core::marker::Send for tst_pipeline::ext::pairing::PairerConfig
impl core::marker::Sync for tst_pipeline::ext::pairing::PairerConfig
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairerConfig
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairerConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairerConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairerConfig
pub struct tst_pipeline::ext::pairing::PairerStats
pub tst_pipeline::ext::pairing::PairerStats::paired: u64
pub tst_pipeline::ext::pairing::PairerStats::pass_through: u64
pub tst_pipeline::ext::pairing::PairerStats::unpaired_klv: u64
pub tst_pipeline::ext::pairing::PairerStats::unpaired_video: u64
impl core::clone::Clone for tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::PairerStats::clone(&self) -> tst_pipeline::ext::pairing::PairerStats
impl core::cmp::Eq for tst_pipeline::ext::pairing::PairerStats
impl core::cmp::PartialEq for tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::PairerStats::eq(&self, &tst_pipeline::ext::pairing::PairerStats) -> bool
impl core::default::Default for tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::PairerStats::default() -> tst_pipeline::ext::pairing::PairerStats
impl core::fmt::Debug for tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::PairerStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::ext::pairing::PairerStats
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairerStats
impl core::marker::Send for tst_pipeline::ext::pairing::PairerStats
impl core::marker::Sync for tst_pipeline::ext::pairing::PairerStats
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairerStats
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairerStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairerStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairerStats
pub struct tst_pipeline::ext::pairing::PairingDemuxer
impl tst_pipeline::ext::pairing::PairingDemuxer
pub fn tst_pipeline::ext::pairing::PairingDemuxer::demuxer_stats(&self) -> tst_core::mpegts::demux::types::DemuxerStats
pub fn tst_pipeline::ext::pairing::PairingDemuxer::feed(&mut self, &[u8]) -> core::result::Result<alloc::vec::Vec<tst_pipeline::ext::pairing::PairerOutput>, tst_core::error::DemuxError>
pub fn tst_pipeline::ext::pairing::PairingDemuxer::flush(&mut self) -> alloc::vec::Vec<tst_pipeline::ext::pairing::PairerOutput>
pub fn tst_pipeline::ext::pairing::PairingDemuxer::last_before_pts(u16, u16, core::option::Option<core::time::Duration>, tst_core::mpegts::demux::types::DemuxerConfig) -> Self
pub fn tst_pipeline::ext::pairing::PairingDemuxer::new(u16, u16) -> Self
pub fn tst_pipeline::ext::pairing::PairingDemuxer::reset_stats(&mut self)
pub fn tst_pipeline::ext::pairing::PairingDemuxer::stats(&self) -> tst_pipeline::ext::pairing::PairerStats
pub fn tst_pipeline::ext::pairing::PairingDemuxer::with_config(u16, u16, tst_pipeline::ext::pairing::PairingDemuxerConfig) -> Self
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairingDemuxer
impl core::marker::Send for tst_pipeline::ext::pairing::PairingDemuxer
impl core::marker::Sync for tst_pipeline::ext::pairing::PairingDemuxer
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairingDemuxer
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairingDemuxer
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairingDemuxer
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairingDemuxer
#[non_exhaustive] pub struct tst_pipeline::ext::pairing::PairingDemuxerConfig
pub tst_pipeline::ext::pairing::PairingDemuxerConfig::demuxer: tst_core::mpegts::demux::types::DemuxerConfig
pub tst_pipeline::ext::pairing::PairingDemuxerConfig::pairer: tst_pipeline::ext::pairing::PairerConfig
impl core::clone::Clone for tst_pipeline::ext::pairing::PairingDemuxerConfig
pub fn tst_pipeline::ext::pairing::PairingDemuxerConfig::clone(&self) -> tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::default::Default for tst_pipeline::ext::pairing::PairingDemuxerConfig
pub fn tst_pipeline::ext::pairing::PairingDemuxerConfig::default() -> tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::fmt::Debug for tst_pipeline::ext::pairing::PairingDemuxerConfig
pub fn tst_pipeline::ext::pairing::PairingDemuxerConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::marker::Send for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::marker::Sync for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::marker::Unpin for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::PairingDemuxerConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::PairingDemuxerConfig
pub struct tst_pipeline::ext::pairing::VideoSample
pub tst_pipeline::ext::pairing::VideoSample::av1_carriage: core::option::Option<tst_core::mpegts::mux::types::Av1CarriageMode>
pub tst_pipeline::ext::pairing::VideoSample::codec: tst_core::mpegts::demux::event::VideoCodec
pub tst_pipeline::ext::pairing::VideoSample::dts: core::option::Option<tst_core::mpegts::common::Pts90khz>
pub tst_pipeline::ext::pairing::VideoSample::pts: tst_core::mpegts::common::Pts90khz
pub tst_pipeline::ext::pairing::VideoSample::random_access_indicator: bool
pub tst_pipeline::ext::pairing::VideoSample::raw: tst_core::shared::SharedBytes
pub tst_pipeline::ext::pairing::VideoSample::stream: tst_core::mpegts::demux::event::StreamId
impl tst_pipeline::ext::pairing::VideoSample
pub fn tst_pipeline::ext::pairing::VideoSample::split_units(&self) -> (tst_core::mpegts::demux::event::VideoPayload, alloc::vec::Vec<tst_core::mpegts::demux::event::NonConformantIssue>)
impl core::clone::Clone for tst_pipeline::ext::pairing::VideoSample
pub fn tst_pipeline::ext::pairing::VideoSample::clone(&self) -> tst_pipeline::ext::pairing::VideoSample
impl core::cmp::Eq for tst_pipeline::ext::pairing::VideoSample
impl core::cmp::PartialEq for tst_pipeline::ext::pairing::VideoSample
pub fn tst_pipeline::ext::pairing::VideoSample::eq(&self, &tst_pipeline::ext::pairing::VideoSample) -> bool
impl core::fmt::Debug for tst_pipeline::ext::pairing::VideoSample
pub fn tst_pipeline::ext::pairing::VideoSample::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::ext::pairing::VideoSample
impl core::marker::Freeze for tst_pipeline::ext::pairing::VideoSample
impl core::marker::Send for tst_pipeline::ext::pairing::VideoSample
impl core::marker::Sync for tst_pipeline::ext::pairing::VideoSample
impl core::marker::Unpin for tst_pipeline::ext::pairing::VideoSample
impl core::marker::UnsafeUnpin for tst_pipeline::ext::pairing::VideoSample
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::pairing::VideoSample
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::pairing::VideoSample
pub mod tst_pipeline::managed_demux_receiver
pub struct tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::new(tst_pipeline::managed_receive::ManagedRecvTransport<R>, tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig) -> Self
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::recv_event(&mut self) -> core::result::Result<core::option::Option<tst_core::mpegts::demux::event::DemuxEvent>, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::stats(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::with_demux_options(tst_pipeline::managed_receive::ManagedRecvTransport<R>, tst_core::mpegts::demux::types::DemuxerConfig, tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig) -> Self
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::iter::traits::iterator::Iterator for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Item = core::result::Result<tst_core::mpegts::demux::event::DemuxEvent, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::next(&mut self) -> core::option::Option<Self::Item>
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> !core::marker::Sync for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> core::marker::Unpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
#[non_exhaustive] pub struct tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::clone::Clone for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::clone(&self) -> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::default::Default for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::default() -> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::fmt::Debug for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Send for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Sync for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Unpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub mod tst_pipeline::managed_receive
pub struct tst_pipeline::managed_receive::ManagedRecvTransport<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::new(R, alloc::boxed::Box<(dyn core::ops::function::FnMut() -> core::result::Result<R, tst_core::transport::TransportError> + core::marker::Send)>, tst_pipeline::reconnect::ReconnectPolicy) -> Self
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
impl<R: tst_core::transport::RecvTransport> tst_core::transport::RecvTransport for tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::close(&mut self)
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::is_alive(&self) -> bool
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::max_payload(&self) -> usize
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::recv_bytes(&mut self, &mut [u8]) -> core::result::Result<usize, tst_core::transport::TransportError>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl<R> core::marker::Freeze for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> !core::marker::Sync for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> core::marker::Unpin for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub mod tst_pipeline::mux_publisher
#[non_exhaustive] pub enum tst_pipeline::mux_publisher::MuxPublisherError<E: core::error::Error + core::marker::Send + core::marker::Sync + 'static>
pub tst_pipeline::mux_publisher::MuxPublisherError::Closed
pub tst_pipeline::mux_publisher::MuxPublisherError::Mux(tst_core::error::MuxError)
pub tst_pipeline::mux_publisher::MuxPublisherError::Publisher(E)
impl<E: core::error::Error + core::marker::Send + core::marker::Sync + 'static> tst_pipeline::mux_publisher::MuxPublisherError<E>
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl<E: core::fmt::Debug + core::error::Error + core::marker::Send + core::marker::Sync + 'static> core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisherError<E>
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E> core::error::Error for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::error::Error + 'static + core::error::Error + core::marker::Send + core::marker::Sync, Self: core::fmt::Debug + core::fmt::Display
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl<E> core::fmt::Display for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::fmt::Display + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E> core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::Freeze
impl<E> core::marker::Send for tst_pipeline::mux_publisher::MuxPublisherError<E>
impl<E> core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisherError<E>
impl<E> core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::Unpin
impl<E> core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::UnsafeUnpin
impl<E> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::panic::unwind_safe::RefUnwindSafe
impl<E> core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::panic::unwind_safe::UnwindSafe
pub struct tst_pipeline::mux_publisher::MuxPublisher<P: tst_core::publisher::Publisher>
impl<P: tst_core::publisher::Publisher> tst_pipeline::mux_publisher::MuxPublisher<P>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::cut_segment(&self) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::finish(self) -> core::result::Result<P, tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::publisher_stats(&self) -> tst_core::publisher::PublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_audio(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_data(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_klv(&self, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_subtitle(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_video(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::stats(&self) -> tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::with_config(P, tst_core::mpegts::mux::config::MuxerConfig) -> core::result::Result<Self, tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
impl<P: tst_core::publisher::Publisher> core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisher<P>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<P> !core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisher<P>
impl<P> core::marker::Send for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Send
impl<P> core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Send
impl<P> core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Unpin
impl<P> core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::UnsafeUnpin
impl<P> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisher<P>
impl<P> core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisher<P>
#[non_exhaustive] pub struct tst_pipeline::mux_publisher::MuxPublisherStats
pub tst_pipeline::mux_publisher::MuxPublisherStats::bytes_pushed: u64
pub tst_pipeline::mux_publisher::MuxPublisherStats::cut_calls: u64
pub tst_pipeline::mux_publisher::MuxPublisherStats::drain_calls: u64
impl core::clone::Clone for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::clone(&self) -> tst_pipeline::mux_publisher::MuxPublisherStats
impl core::default::Default for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::default() -> tst_pipeline::mux_publisher::MuxPublisherStats
impl core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Send for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisherStats
pub mod tst_pipeline::mux_sender
#[non_exhaustive] pub enum tst_pipeline::mux_sender::MuxSenderErrorSource
pub tst_pipeline::mux_sender::MuxSenderErrorSource::Mux(tst_core::error::MuxError)
pub tst_pipeline::mux_sender::MuxSenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderErrorSource
pub struct tst_pipeline::mux_sender::MuxSender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::audio_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::AudioStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::audio_handles_for_program(&self, u16) -> core::result::Result<alloc::vec::Vec<tst_core::mpegts::mux::types::AudioStreamHandle>, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&self)
pub fn tst_pipeline::mux_sender::MuxSender<T>::data_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::DataStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::mux_sender::MuxSender<T>::klv_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::KlvStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::new(T, tst_core::mpegts::mux::config::MuxerConfig) -> core::result::Result<Self, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::reset_stats(&self)
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_audio(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_audio_to(&self, tst_core::mpegts::mux::types::AudioStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_data(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_data_to(&self, tst_core::mpegts::mux::types::DataStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_klv(&self, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_klv_to(&self, tst_core::mpegts::mux::types::KlvStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_subtitle(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_subtitle_to(&self, tst_core::mpegts::mux::types::SubtitleStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_to(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_to_with_dts(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::mux_sender::MuxSender<T>::stats(&self) -> tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSender<T>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
pub fn tst_pipeline::mux_sender::MuxSender<T>::subtitle_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::SubtitleStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::subtitle_handles_for_program(&self, u16) -> core::result::Result<alloc::vec::Vec<tst_core::mpegts::mux::types::SubtitleStreamHandle>, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::video_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::VideoStreamHandle>
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::drop(&mut self)
impl<T> !core::marker::Freeze for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Send for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Sync for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Unpin for tst_pipeline::mux_sender::MuxSender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSender<T> where T: core::marker::UnsafeUnpin
impl<T> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSender<T>
impl<T> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSender<T>
#[non_exhaustive] pub struct tst_pipeline::mux_sender::MuxSenderError
pub tst_pipeline::mux_sender::MuxSenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::mux_sender::MuxSenderError::source: tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::mux_sender::MuxSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderError
pub struct tst_pipeline::mux_sender::MuxSenderStats
pub tst_pipeline::mux_sender::MuxSenderStats::bytes_sent: u64
pub tst_pipeline::mux_sender::MuxSenderStats::packets_sent: u64
pub tst_pipeline::mux_sender::MuxSenderStats::pending_bytes_queued: u64
pub tst_pipeline::mux_sender::MuxSenderStats::pending_chunks_queued: u64
pub tst_pipeline::mux_sender::MuxSenderStats::per_stream: alloc::collections::btree::map::BTreeMap<u16, tst_core::mpegts::stats::StreamStats>
pub tst_pipeline::mux_sender::MuxSenderStats::programs_configured: u32
impl core::clone::Clone for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::clone(&self) -> tst_pipeline::mux_sender::MuxSenderStats
impl core::cmp::Eq for tst_pipeline::mux_sender::MuxSenderStats
impl core::cmp::PartialEq for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::eq(&self, &tst_pipeline::mux_sender::MuxSenderStats) -> bool
impl core::default::Default for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::default() -> tst_pipeline::mux_sender::MuxSenderStats
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderStats
pub type tst_pipeline::mux_sender::BoxedMuxSender = tst_pipeline::mux_sender::MuxSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub mod tst_pipeline::raw_receiver
#[non_exhaustive] pub enum tst_pipeline::raw_receiver::RawReceiverErrorSource
pub tst_pipeline::raw_receiver::RawReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub struct tst_pipeline::raw_receiver::RawReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self)
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::new(R, tst_pipeline::raw_receiver::RawReceiverConfig) -> Self
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::recv_one(&mut self) -> core::result::Result<alloc::vec::Vec<u8>, tst_pipeline::raw_receiver::RawReceiverError>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::stats(&self) -> tst_pipeline::raw_receiver::RawRecvStats
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::raw_receiver::RawReceiver<R>
impl<R> core::marker::Sync for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::raw_receiver::RawReceiverConfig
impl core::clone::Clone for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::clone(&self) -> tst_pipeline::raw_receiver::RawReceiverConfig
impl core::default::Default for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::default() -> tst_pipeline::raw_receiver::RawReceiverConfig
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverConfig
#[non_exhaustive] pub struct tst_pipeline::raw_receiver::RawReceiverError
pub tst_pipeline::raw_receiver::RawReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::raw_receiver::RawReceiverError::source: tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_receiver::RawReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverError
pub struct tst_pipeline::raw_receiver::RawRecvStats
pub tst_pipeline::raw_receiver::RawRecvStats::bytes_received: u64
pub tst_pipeline::raw_receiver::RawRecvStats::packets_received: u64
impl core::clone::Clone for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::clone(&self) -> tst_pipeline::raw_receiver::RawRecvStats
impl core::cmp::Eq for tst_pipeline::raw_receiver::RawRecvStats
impl core::cmp::PartialEq for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::eq(&self, &tst_pipeline::raw_receiver::RawRecvStats) -> bool
impl core::default::Default for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::default() -> tst_pipeline::raw_receiver::RawRecvStats
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::StructuralPartialEq for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Send for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Sync for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawRecvStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawRecvStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawRecvStats
pub type tst_pipeline::raw_receiver::BoxedRawReceiver = tst_pipeline::raw_receiver::RawReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub mod tst_pipeline::raw_sender
#[non_exhaustive] pub enum tst_pipeline::raw_sender::RawSenderErrorSource
pub tst_pipeline::raw_sender::RawSenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderErrorSource
pub struct tst_pipeline::raw_sender::RawSendStats
pub tst_pipeline::raw_sender::RawSendStats::bytes_sent: u64
pub tst_pipeline::raw_sender::RawSendStats::packets_sent: u64
impl core::clone::Clone for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::clone(&self) -> tst_pipeline::raw_sender::RawSendStats
impl core::cmp::Eq for tst_pipeline::raw_sender::RawSendStats
impl core::cmp::PartialEq for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::eq(&self, &tst_pipeline::raw_sender::RawSendStats) -> bool
impl core::default::Default for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::default() -> tst_pipeline::raw_sender::RawSendStats
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::raw_sender::RawSendStats
impl core::marker::StructuralPartialEq for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Send for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Sync for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSendStats
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSendStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSendStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSendStats
pub struct tst_pipeline::raw_sender::RawSender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self)
pub fn tst_pipeline::raw_sender::RawSender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::raw_sender::RawSender<T>::new(T, tst_pipeline::raw_sender::RawSenderConfig) -> Self
pub fn tst_pipeline::raw_sender::RawSender<T>::reset_stats(&mut self)
pub fn tst_pipeline::raw_sender::RawSender<T>::send(&mut self, &[u8]) -> core::result::Result<(), tst_pipeline::raw_sender::RawSenderError>
pub fn tst_pipeline::raw_sender::RawSender<T>::stats(&self) -> tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSender<T>::transport(&self) -> &T
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::drop(&mut self)
impl<T> core::marker::Freeze for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::raw_sender::RawSender<T>
impl<T> core::marker::Sync for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSender<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSender<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::raw_sender::RawSenderConfig
impl core::clone::Clone for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::clone(&self) -> tst_pipeline::raw_sender::RawSenderConfig
impl core::default::Default for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::default() -> tst_pipeline::raw_sender::RawSenderConfig
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderConfig
#[non_exhaustive] pub struct tst_pipeline::raw_sender::RawSenderError
pub tst_pipeline::raw_sender::RawSenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::raw_sender::RawSenderError::source: tst_pipeline::raw_sender::RawSenderErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_sender::RawSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderError
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderError
pub type tst_pipeline::raw_sender::BoxedRawSender = tst_pipeline::raw_sender::RawSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub mod tst_pipeline::receiver
pub mod tst_pipeline::receiver::sync
pub enum tst_pipeline::receiver::sync::SyncState
pub tst_pipeline::receiver::sync::SyncState::Hunt
pub tst_pipeline::receiver::sync::SyncState::Locked
pub tst_pipeline::receiver::sync::SyncState::Verify
pub tst_pipeline::receiver::sync::SyncState::Verify::count: u8
impl core::clone::Clone for tst_pipeline::receiver::sync::SyncState
pub fn tst_pipeline::receiver::sync::SyncState::clone(&self) -> tst_pipeline::receiver::sync::SyncState
impl core::cmp::Eq for tst_pipeline::receiver::sync::SyncState
impl core::cmp::PartialEq for tst_pipeline::receiver::sync::SyncState
pub fn tst_pipeline::receiver::sync::SyncState::eq(&self, &tst_pipeline::receiver::sync::SyncState) -> bool
impl core::fmt::Debug for tst_pipeline::receiver::sync::SyncState
pub fn tst_pipeline::receiver::sync::SyncState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::receiver::sync::SyncState
impl core::marker::StructuralPartialEq for tst_pipeline::receiver::sync::SyncState
impl core::marker::Freeze for tst_pipeline::receiver::sync::SyncState
impl core::marker::Send for tst_pipeline::receiver::sync::SyncState
impl core::marker::Sync for tst_pipeline::receiver::sync::SyncState
impl core::marker::Unpin for tst_pipeline::receiver::sync::SyncState
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::sync::SyncState
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::sync::SyncState
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::sync::SyncState
pub struct tst_pipeline::receiver::sync::Syncer
impl tst_pipeline::receiver::sync::Syncer
pub fn tst_pipeline::receiver::sync::Syncer::new() -> Self
pub fn tst_pipeline::receiver::sync::Syncer::next_packet(&mut self) -> core::option::Option<[u8; 188]>
pub fn tst_pipeline::receiver::sync::Syncer::push(&mut self, &[u8])
pub fn tst_pipeline::receiver::sync::Syncer::reset(&mut self)
impl core::default::Default for tst_pipeline::receiver::sync::Syncer
pub fn tst_pipeline::receiver::sync::Syncer::default() -> Self
impl core::fmt::Debug for tst_pipeline::receiver::sync::Syncer
pub fn tst_pipeline::receiver::sync::Syncer::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::receiver::sync::Syncer
impl core::marker::Send for tst_pipeline::receiver::sync::Syncer
impl core::marker::Sync for tst_pipeline::receiver::sync::Syncer
impl core::marker::Unpin for tst_pipeline::receiver::sync::Syncer
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::sync::Syncer
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::sync::Syncer
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::sync::Syncer
#[non_exhaustive] pub enum tst_pipeline::receiver::ReceiverErrorSource
pub tst_pipeline::receiver::ReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Send for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Sync for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverErrorSource
pub struct tst_pipeline::receiver::Receiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::receiver::Receiver<R>::new(R, tst_pipeline::receiver::ReceiverConfig) -> Self
pub fn tst_pipeline::receiver::Receiver<R>::next_packet(&mut self) -> core::result::Result<[u8; 188], tst_pipeline::receiver::ReceiverError>
pub fn tst_pipeline::receiver::Receiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::reset_sync(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::receiver::Receiver<R>::stats(&self) -> tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::Receiver<R>::transport(&self) -> &R
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::receiver::Receiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::receiver::Receiver<R>
impl<R> core::marker::Sync for tst_pipeline::receiver::Receiver<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::receiver::Receiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::receiver::Receiver<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::Receiver<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::Receiver<R> where R: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::receiver::ReceiverConfig
impl core::clone::Clone for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::clone(&self) -> tst_pipeline::receiver::ReceiverConfig
impl core::default::Default for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::default() -> tst_pipeline::receiver::ReceiverConfig
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Send for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Sync for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverConfig
#[non_exhaustive] pub struct tst_pipeline::receiver::ReceiverError
pub tst_pipeline::receiver::ReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::receiver::ReceiverError::source: tst_pipeline::receiver::ReceiverErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::receiver::ReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverError
impl core::marker::Send for tst_pipeline::receiver::ReceiverError
impl core::marker::Sync for tst_pipeline::receiver::ReceiverError
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverError
pub struct tst_pipeline::receiver::ReceiverStats
pub tst_pipeline::receiver::ReceiverStats::bytes_received: u64
pub tst_pipeline::receiver::ReceiverStats::bytes_skipped_for_sync: u64
pub tst_pipeline::receiver::ReceiverStats::packets_received: u64
pub tst_pipeline::receiver::ReceiverStats::resync_events: u64
impl core::clone::Clone for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::clone(&self) -> tst_pipeline::receiver::ReceiverStats
impl core::cmp::Eq for tst_pipeline::receiver::ReceiverStats
impl core::cmp::PartialEq for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::eq(&self, &tst_pipeline::receiver::ReceiverStats) -> bool
impl core::default::Default for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::default() -> tst_pipeline::receiver::ReceiverStats
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::receiver::ReceiverStats
impl core::marker::StructuralPartialEq for tst_pipeline::receiver::ReceiverStats
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverStats
impl core::marker::Send for tst_pipeline::receiver::ReceiverStats
impl core::marker::Sync for tst_pipeline::receiver::ReceiverStats
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverStats
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverStats
pub type tst_pipeline::receiver::BoxedReceiver = tst_pipeline::receiver::Receiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub mod tst_pipeline::reconnect
pub enum tst_pipeline::reconnect::BackoffStrategy
pub tst_pipeline::reconnect::BackoffStrategy::Constant(core::time::Duration)
pub tst_pipeline::reconnect::BackoffStrategy::Exponential
pub tst_pipeline::reconnect::BackoffStrategy::Exponential::base: core::time::Duration
pub tst_pipeline::reconnect::BackoffStrategy::Exponential::max: core::time::Duration
impl core::clone::Clone for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::clone(&self) -> tst_pipeline::reconnect::BackoffStrategy
impl core::cmp::Eq for tst_pipeline::reconnect::BackoffStrategy
impl core::cmp::PartialEq for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::eq(&self, &tst_pipeline::reconnect::BackoffStrategy) -> bool
impl core::default::Default for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::default() -> Self
impl core::fmt::Debug for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Freeze for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Send for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Sync for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Unpin for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::BackoffStrategy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::BackoffStrategy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::BackoffStrategy
pub enum tst_pipeline::reconnect::OverflowPolicy
pub tst_pipeline::reconnect::OverflowPolicy::DropOldest
pub tst_pipeline::reconnect::OverflowPolicy::Reject
impl core::clone::Clone for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::clone(&self) -> tst_pipeline::OverflowPolicy
impl core::cmp::Eq for tst_pipeline::OverflowPolicy
impl core::cmp::PartialEq for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::eq(&self, &tst_pipeline::OverflowPolicy) -> bool
impl core::default::Default for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::default() -> tst_pipeline::OverflowPolicy
impl core::fmt::Debug for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::OverflowPolicy
impl core::marker::StructuralPartialEq for tst_pipeline::OverflowPolicy
impl core::marker::Freeze for tst_pipeline::OverflowPolicy
impl core::marker::Send for tst_pipeline::OverflowPolicy
impl core::marker::Sync for tst_pipeline::OverflowPolicy
impl core::marker::Unpin for tst_pipeline::OverflowPolicy
impl core::marker::UnsafeUnpin for tst_pipeline::OverflowPolicy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::OverflowPolicy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::OverflowPolicy
pub struct tst_pipeline::reconnect::GapBuffer
pub tst_pipeline::reconnect::GapBuffer::bytes_dropped: u64
pub tst_pipeline::reconnect::GapBuffer::messages_dropped: u64
impl tst_pipeline::GapBuffer
pub fn tst_pipeline::GapBuffer::enqueue(&mut self, alloc::vec::Vec<u8>) -> core::result::Result<(), tst_pipeline::reconnect::gap_buffer::GapBufferError>
pub fn tst_pipeline::GapBuffer::front(&self) -> core::option::Option<&alloc::vec::Vec<u8>>
pub fn tst_pipeline::GapBuffer::is_empty(&self) -> bool
pub fn tst_pipeline::GapBuffer::len(&self) -> usize
pub fn tst_pipeline::GapBuffer::new(usize, tst_pipeline::OverflowPolicy) -> Self
pub fn tst_pipeline::GapBuffer::pop_front(&mut self) -> core::option::Option<alloc::vec::Vec<u8>>
impl core::marker::Freeze for tst_pipeline::GapBuffer
impl core::marker::Send for tst_pipeline::GapBuffer
impl core::marker::Sync for tst_pipeline::GapBuffer
impl core::marker::Unpin for tst_pipeline::GapBuffer
impl core::marker::UnsafeUnpin for tst_pipeline::GapBuffer
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::GapBuffer
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::GapBuffer
pub struct tst_pipeline::reconnect::ManagedTransport<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport + 'static> tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::new<F>(T, F, tst_pipeline::reconnect::ReconnectPolicy) -> Self where F: core::ops::function::Fn() -> core::result::Result<T, tst_core::transport::TransportError> + core::marker::Send + core::marker::Sync + 'static
impl<T: tst_core::transport::Transport + 'static> tst_core::transport::Transport for tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::close(&mut self)
pub fn tst_pipeline::reconnect::ManagedTransport<T>::is_alive(&self) -> bool
pub fn tst_pipeline::reconnect::ManagedTransport<T>::max_payload(&self) -> usize
pub fn tst_pipeline::reconnect::ManagedTransport<T>::send_bytes(&mut self, &[u8]) -> core::result::Result<(), tst_core::transport::TransportError>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl<T> core::marker::Freeze for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Send for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Sync for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Unpin for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedTransport<T>
pub struct tst_pipeline::reconnect::ReconnectPolicy
pub tst_pipeline::reconnect::ReconnectPolicy::backoff: tst_pipeline::reconnect::BackoffStrategy
pub tst_pipeline::reconnect::ReconnectPolicy::gap_buffer_capacity: usize
pub tst_pipeline::reconnect::ReconnectPolicy::max_attempts: core::option::Option<u32>
pub tst_pipeline::reconnect::ReconnectPolicy::overflow_policy: tst_pipeline::OverflowPolicy
impl tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::next_delay(&self, u32) -> core::option::Option<core::time::Duration>
impl core::clone::Clone for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::clone(&self) -> tst_pipeline::reconnect::ReconnectPolicy
impl core::default::Default for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::default() -> Self
impl core::fmt::Debug for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Send for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Sync for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Unpin for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ReconnectPolicy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ReconnectPolicy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ReconnectPolicy
pub mod tst_pipeline::sender
#[non_exhaustive] pub enum tst_pipeline::sender::SenderErrorSource
pub tst_pipeline::sender::SenderErrorSource::Framing(tst_pipeline::sender::TsFramingError)
pub tst_pipeline::sender::SenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::sender::SenderErrorSource
impl core::marker::Send for tst_pipeline::sender::SenderErrorSource
impl core::marker::Sync for tst_pipeline::sender::SenderErrorSource
impl core::marker::Unpin for tst_pipeline::sender::SenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderErrorSource
#[non_exhaustive] pub enum tst_pipeline::sender::TsFramingError
pub tst_pipeline::sender::TsFramingError::NoSyncAfterLimit
pub tst_pipeline::sender::TsFramingError::NoSyncAfterLimit::max: u64
pub tst_pipeline::sender::TsFramingError::SyncLost
pub tst_pipeline::sender::TsFramingError::SyncLost::offset: u64
impl core::clone::Clone for tst_pipeline::sender::TsFramingError
pub fn tst_pipeline::sender::TsFramingError::clone(&self) -> tst_pipeline::sender::TsFramingError
impl core::cmp::Eq for tst_pipeline::sender::TsFramingError
impl core::cmp::PartialEq for tst_pipeline::sender::TsFramingError
pub fn tst_pipeline::sender::TsFramingError::eq(&self, &tst_pipeline::sender::TsFramingError) -> bool
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::sender::TsFramingError
impl core::fmt::Debug for tst_pipeline::sender::TsFramingError
pub fn tst_pipeline::sender::TsFramingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::sender::TsFramingError
pub fn tst_pipeline::sender::TsFramingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::sender::TsFramingError
impl core::marker::Freeze for tst_pipeline::sender::TsFramingError
impl core::marker::Send for tst_pipeline::sender::TsFramingError
impl core::marker::Sync for tst_pipeline::sender::TsFramingError
impl core::marker::Unpin for tst_pipeline::sender::TsFramingError
impl core::marker::UnsafeUnpin for tst_pipeline::sender::TsFramingError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::TsFramingError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::TsFramingError
pub enum tst_pipeline::sender::TsFramingMode
pub tst_pipeline::sender::TsFramingMode::Recover
pub tst_pipeline::sender::TsFramingMode::Strict
impl core::clone::Clone for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::clone(&self) -> tst_pipeline::TsFramingMode
impl core::cmp::Eq for tst_pipeline::TsFramingMode
impl core::cmp::PartialEq for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::eq(&self, &tst_pipeline::TsFramingMode) -> bool
impl core::default::Default for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::default() -> tst_pipeline::TsFramingMode
impl core::fmt::Debug for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::TsFramingMode
impl core::marker::StructuralPartialEq for tst_pipeline::TsFramingMode
impl core::marker::Freeze for tst_pipeline::TsFramingMode
impl core::marker::Send for tst_pipeline::TsFramingMode
impl core::marker::Sync for tst_pipeline::TsFramingMode
impl core::marker::Unpin for tst_pipeline::TsFramingMode
impl core::marker::UnsafeUnpin for tst_pipeline::TsFramingMode
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::TsFramingMode
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::TsFramingMode
pub struct tst_pipeline::sender::Sender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::sender::Sender<T>::close(&mut self)
pub fn tst_pipeline::sender::Sender<T>::flush(&mut self) -> core::result::Result<(), tst_pipeline::sender::SenderError>
pub fn tst_pipeline::sender::Sender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::sender::Sender<T>::new(T, tst_pipeline::sender::SenderConfig) -> Self
pub fn tst_pipeline::sender::Sender<T>::reset_stats(&mut self)
pub fn tst_pipeline::sender::Sender<T>::send_ts(&mut self, &[u8]) -> core::result::Result<(), tst_pipeline::sender::SenderError>
pub fn tst_pipeline::sender::Sender<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::sender::Sender<T>::stats(&self) -> tst_pipeline::SenderStats
pub fn tst_pipeline::sender::Sender<T>::transport(&self) -> &T
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::drop(&mut self)
impl<T> core::marker::Freeze for tst_pipeline::sender::Sender<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::sender::Sender<T>
impl<T> core::marker::Sync for tst_pipeline::sender::Sender<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::sender::Sender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::sender::Sender<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::Sender<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::Sender<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::sender::SenderConfig
pub tst_pipeline::sender::SenderConfig::framing_mode: tst_pipeline::TsFramingMode
pub tst_pipeline::sender::SenderConfig::max_unsynced_bytes: usize
impl core::clone::Clone for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::clone(&self) -> tst_pipeline::sender::SenderConfig
impl core::default::Default for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::default() -> Self
impl core::fmt::Debug for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::sender::SenderConfig
impl core::marker::Send for tst_pipeline::sender::SenderConfig
impl core::marker::Sync for tst_pipeline::sender::SenderConfig
impl core::marker::Unpin for tst_pipeline::sender::SenderConfig
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderConfig
#[non_exhaustive] pub struct tst_pipeline::sender::SenderError
pub tst_pipeline::sender::SenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::sender::SenderError::source: tst_pipeline::sender::SenderErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::sender::SenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::sender::SenderError
impl core::marker::Send for tst_pipeline::sender::SenderError
impl core::marker::Sync for tst_pipeline::sender::SenderError
impl core::marker::Unpin for tst_pipeline::sender::SenderError
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderError
pub struct tst_pipeline::sender::SenderStats
pub tst_pipeline::sender::SenderStats::bytes_pushed: u64
pub tst_pipeline::sender::SenderStats::bytes_skipped_for_sync: u64
pub tst_pipeline::sender::SenderStats::packets_sent: u64
pub tst_pipeline::sender::SenderStats::resync_events: u64
impl core::clone::Clone for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::clone(&self) -> tst_pipeline::SenderStats
impl core::cmp::Eq for tst_pipeline::SenderStats
impl core::cmp::PartialEq for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::eq(&self, &tst_pipeline::SenderStats) -> bool
impl core::default::Default for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::default() -> tst_pipeline::SenderStats
impl core::fmt::Debug for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::SenderStats
impl core::marker::Freeze for tst_pipeline::SenderStats
impl core::marker::Send for tst_pipeline::SenderStats
impl core::marker::Sync for tst_pipeline::SenderStats
impl core::marker::Unpin for tst_pipeline::SenderStats
impl core::marker::UnsafeUnpin for tst_pipeline::SenderStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::SenderStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::SenderStats
pub struct tst_pipeline::sender::TsFraming
impl tst_pipeline::sender::TsFraming
pub fn tst_pipeline::sender::TsFraming::flush(&mut self) -> alloc::vec::Vec<alloc::vec::Vec<u8>>
pub fn tst_pipeline::sender::TsFraming::is_synced(&self) -> bool
pub fn tst_pipeline::sender::TsFraming::new(usize) -> Self
pub fn tst_pipeline::sender::TsFraming::push(&mut self, &[u8]) -> (alloc::vec::Vec<alloc::vec::Vec<u8>>, &tst_pipeline::SenderStats)
pub fn tst_pipeline::sender::TsFraming::push_strict(&mut self, &[u8]) -> core::result::Result<alloc::vec::Vec<alloc::vec::Vec<u8>>, tst_pipeline::sender::TsFramingError>
pub fn tst_pipeline::sender::TsFraming::reset_stats(&mut self)
pub fn tst_pipeline::sender::TsFraming::stats(&self) -> tst_pipeline::SenderStats
impl core::marker::Freeze for tst_pipeline::sender::TsFraming
impl core::marker::Send for tst_pipeline::sender::TsFraming
impl core::marker::Sync for tst_pipeline::sender::TsFraming
impl core::marker::Unpin for tst_pipeline::sender::TsFraming
impl core::marker::UnsafeUnpin for tst_pipeline::sender::TsFraming
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::TsFraming
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::TsFraming
pub type tst_pipeline::sender::BoxedSender = tst_pipeline::sender::Sender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub mod tst_pipeline::shell_error
#[non_exhaustive] pub enum tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::shell_error::ShellErrorKind::Backpressure
pub tst_pipeline::shell_error::ShellErrorKind::Closed
pub tst_pipeline::shell_error::ShellErrorKind::ConfigInvalid
pub tst_pipeline::shell_error::ShellErrorKind::EndOfStream
pub tst_pipeline::shell_error::ShellErrorKind::InputMalformed
pub tst_pipeline::shell_error::ShellErrorKind::TransportBroken
impl core::clone::Clone for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::clone(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::cmp::Eq for tst_pipeline::shell_error::ShellErrorKind
impl core::cmp::PartialEq for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::eq(&self, &tst_pipeline::shell_error::ShellErrorKind) -> bool
impl core::fmt::Debug for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::StructuralPartialEq for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Send for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Sync for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Unpin for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::UnsafeUnpin for tst_pipeline::shell_error::ShellErrorKind
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::shell_error::ShellErrorKind
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::shell_error::ShellErrorKind
pub trait tst_pipeline::shell_error::ShellError: core::error::Error
pub fn tst_pipeline::shell_error::ShellError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::shell_error::ShellError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::mux_sender::MuxSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_receiver::RawReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_sender::RawSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::receiver::ReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::sender::SenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
pub enum tst_pipeline::BackoffStrategy
pub tst_pipeline::BackoffStrategy::Constant(core::time::Duration)
pub tst_pipeline::BackoffStrategy::Exponential
pub tst_pipeline::BackoffStrategy::Exponential::base: core::time::Duration
pub tst_pipeline::BackoffStrategy::Exponential::max: core::time::Duration
impl core::clone::Clone for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::clone(&self) -> tst_pipeline::reconnect::BackoffStrategy
impl core::cmp::Eq for tst_pipeline::reconnect::BackoffStrategy
impl core::cmp::PartialEq for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::eq(&self, &tst_pipeline::reconnect::BackoffStrategy) -> bool
impl core::default::Default for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::default() -> Self
impl core::fmt::Debug for tst_pipeline::reconnect::BackoffStrategy
pub fn tst_pipeline::reconnect::BackoffStrategy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Freeze for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Send for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Sync for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::Unpin for tst_pipeline::reconnect::BackoffStrategy
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::BackoffStrategy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::BackoffStrategy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::BackoffStrategy
#[non_exhaustive] pub enum tst_pipeline::DemuxReceiverErrorSource
pub tst_pipeline::DemuxReceiverErrorSource::Demux(tst_core::error::DemuxError)
pub tst_pipeline::DemuxReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
pub fn tst_pipeline::demux_receiver::DemuxReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverErrorSource
#[non_exhaustive] pub enum tst_pipeline::MuxPublisherError<E: core::error::Error + core::marker::Send + core::marker::Sync + 'static>
pub tst_pipeline::MuxPublisherError::Closed
pub tst_pipeline::MuxPublisherError::Mux(tst_core::error::MuxError)
pub tst_pipeline::MuxPublisherError::Publisher(E)
impl<E: core::error::Error + core::marker::Send + core::marker::Sync + 'static> tst_pipeline::mux_publisher::MuxPublisherError<E>
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl<E: core::fmt::Debug + core::error::Error + core::marker::Send + core::marker::Sync + 'static> core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisherError<E>
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E> core::error::Error for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::error::Error + 'static + core::error::Error + core::marker::Send + core::marker::Sync, Self: core::fmt::Debug + core::fmt::Display
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl<E> core::fmt::Display for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::fmt::Display + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::mux_publisher::MuxPublisherError<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E> core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::Freeze
impl<E> core::marker::Send for tst_pipeline::mux_publisher::MuxPublisherError<E>
impl<E> core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisherError<E>
impl<E> core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::Unpin
impl<E> core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::marker::UnsafeUnpin
impl<E> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::panic::unwind_safe::RefUnwindSafe
impl<E> core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisherError<E> where E: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub enum tst_pipeline::MuxSenderErrorSource
pub tst_pipeline::MuxSenderErrorSource::Mux(tst_core::error::MuxError)
pub tst_pipeline::MuxSenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::mux_sender::MuxSenderErrorSource
pub fn tst_pipeline::mux_sender::MuxSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderErrorSource
pub enum tst_pipeline::OverflowPolicy
pub tst_pipeline::OverflowPolicy::DropOldest
pub tst_pipeline::OverflowPolicy::Reject
impl core::clone::Clone for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::clone(&self) -> tst_pipeline::OverflowPolicy
impl core::cmp::Eq for tst_pipeline::OverflowPolicy
impl core::cmp::PartialEq for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::eq(&self, &tst_pipeline::OverflowPolicy) -> bool
impl core::default::Default for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::default() -> tst_pipeline::OverflowPolicy
impl core::fmt::Debug for tst_pipeline::OverflowPolicy
pub fn tst_pipeline::OverflowPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::OverflowPolicy
impl core::marker::StructuralPartialEq for tst_pipeline::OverflowPolicy
impl core::marker::Freeze for tst_pipeline::OverflowPolicy
impl core::marker::Send for tst_pipeline::OverflowPolicy
impl core::marker::Sync for tst_pipeline::OverflowPolicy
impl core::marker::Unpin for tst_pipeline::OverflowPolicy
impl core::marker::UnsafeUnpin for tst_pipeline::OverflowPolicy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::OverflowPolicy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::OverflowPolicy
#[non_exhaustive] pub enum tst_pipeline::RawReceiverErrorSource
pub tst_pipeline::RawReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_receiver::RawReceiverErrorSource
pub fn tst_pipeline::raw_receiver::RawReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverErrorSource
#[non_exhaustive] pub enum tst_pipeline::RawSenderErrorSource
pub tst_pipeline::RawSenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_sender::RawSenderErrorSource
pub fn tst_pipeline::raw_sender::RawSenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderErrorSource
#[non_exhaustive] pub enum tst_pipeline::ReceiverErrorSource
pub tst_pipeline::ReceiverErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::receiver::ReceiverErrorSource
pub fn tst_pipeline::receiver::ReceiverErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Send for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Sync for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverErrorSource
#[non_exhaustive] pub enum tst_pipeline::SenderErrorSource
pub tst_pipeline::SenderErrorSource::Framing(tst_pipeline::sender::TsFramingError)
pub tst_pipeline::SenderErrorSource::Transport(tst_core::transport::TransportError)
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::sender::SenderErrorSource
pub fn tst_pipeline::sender::SenderErrorSource::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::sender::SenderErrorSource
impl core::marker::Send for tst_pipeline::sender::SenderErrorSource
impl core::marker::Sync for tst_pipeline::sender::SenderErrorSource
impl core::marker::Unpin for tst_pipeline::sender::SenderErrorSource
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderErrorSource
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderErrorSource
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderErrorSource
#[non_exhaustive] pub enum tst_pipeline::ShellErrorKind
pub tst_pipeline::ShellErrorKind::Backpressure
pub tst_pipeline::ShellErrorKind::Closed
pub tst_pipeline::ShellErrorKind::ConfigInvalid
pub tst_pipeline::ShellErrorKind::EndOfStream
pub tst_pipeline::ShellErrorKind::InputMalformed
pub tst_pipeline::ShellErrorKind::TransportBroken
impl core::clone::Clone for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::clone(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::cmp::Eq for tst_pipeline::shell_error::ShellErrorKind
impl core::cmp::PartialEq for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::eq(&self, &tst_pipeline::shell_error::ShellErrorKind) -> bool
impl core::fmt::Debug for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for tst_pipeline::shell_error::ShellErrorKind
pub fn tst_pipeline::shell_error::ShellErrorKind::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::StructuralPartialEq for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Send for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Sync for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Unpin for tst_pipeline::shell_error::ShellErrorKind
impl core::marker::UnsafeUnpin for tst_pipeline::shell_error::ShellErrorKind
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::shell_error::ShellErrorKind
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::shell_error::ShellErrorKind
pub enum tst_pipeline::TsFramingMode
pub tst_pipeline::TsFramingMode::Recover
pub tst_pipeline::TsFramingMode::Strict
impl core::clone::Clone for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::clone(&self) -> tst_pipeline::TsFramingMode
impl core::cmp::Eq for tst_pipeline::TsFramingMode
impl core::cmp::PartialEq for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::eq(&self, &tst_pipeline::TsFramingMode) -> bool
impl core::default::Default for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::default() -> tst_pipeline::TsFramingMode
impl core::fmt::Debug for tst_pipeline::TsFramingMode
pub fn tst_pipeline::TsFramingMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::TsFramingMode
impl core::marker::StructuralPartialEq for tst_pipeline::TsFramingMode
impl core::marker::Freeze for tst_pipeline::TsFramingMode
impl core::marker::Send for tst_pipeline::TsFramingMode
impl core::marker::Sync for tst_pipeline::TsFramingMode
impl core::marker::Unpin for tst_pipeline::TsFramingMode
impl core::marker::UnsafeUnpin for tst_pipeline::TsFramingMode
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::TsFramingMode
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::TsFramingMode
pub struct tst_pipeline::DemuxReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::add_byte_sink(&mut self, tst_pipeline::demux_receiver::ByteSink)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::new(R) -> Self
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::recv_event(&mut self) -> core::result::Result<core::option::Option<tst_core::mpegts::demux::event::DemuxEvent>, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::with_demux_options(R, tst_core::mpegts::demux::types::DemuxerConfig) -> Self
impl<R: tst_core::transport::RecvTransport> tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::stats(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::iter::traits::iterator::Iterator for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Item = core::result::Result<tst_core::mpegts::demux::event::DemuxEvent, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::next(&mut self) -> core::option::Option<Self::Item>
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> !core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiver<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiver<R>
#[non_exhaustive] pub struct tst_pipeline::DemuxReceiverError
pub tst_pipeline::DemuxReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::DemuxReceiverError::source: tst_pipeline::demux_receiver::DemuxReceiverErrorSource
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverError
pub struct tst_pipeline::DemuxReceiverStats
pub tst_pipeline::DemuxReceiverStats::bytes_received: u64
pub tst_pipeline::DemuxReceiverStats::discontinuities: u64
pub tst_pipeline::DemuxReceiverStats::nonconformant: u64
pub tst_pipeline::DemuxReceiverStats::packets_received: u64
pub tst_pipeline::DemuxReceiverStats::per_stream: alloc::collections::btree::map::BTreeMap<u16, tst_core::mpegts::stats::StreamStats>
pub tst_pipeline::DemuxReceiverStats::pmt_versions_seen: u64
pub tst_pipeline::DemuxReceiverStats::program_maps_seen: u64
impl core::clone::Clone for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::clone(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::cmp::Eq for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::cmp::PartialEq for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::eq(&self, &tst_pipeline::demux_receiver::DemuxReceiverStats) -> bool
impl core::default::Default for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::default() -> tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::fmt::Debug for tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::demux_receiver::DemuxReceiverStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Freeze for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Send for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Sync for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::Unpin for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::marker::UnsafeUnpin for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::demux_receiver::DemuxReceiverStats
pub struct tst_pipeline::GapBuffer
pub tst_pipeline::GapBuffer::bytes_dropped: u64
pub tst_pipeline::GapBuffer::messages_dropped: u64
impl tst_pipeline::GapBuffer
pub fn tst_pipeline::GapBuffer::enqueue(&mut self, alloc::vec::Vec<u8>) -> core::result::Result<(), tst_pipeline::reconnect::gap_buffer::GapBufferError>
pub fn tst_pipeline::GapBuffer::front(&self) -> core::option::Option<&alloc::vec::Vec<u8>>
pub fn tst_pipeline::GapBuffer::is_empty(&self) -> bool
pub fn tst_pipeline::GapBuffer::len(&self) -> usize
pub fn tst_pipeline::GapBuffer::new(usize, tst_pipeline::OverflowPolicy) -> Self
pub fn tst_pipeline::GapBuffer::pop_front(&mut self) -> core::option::Option<alloc::vec::Vec<u8>>
impl core::marker::Freeze for tst_pipeline::GapBuffer
impl core::marker::Send for tst_pipeline::GapBuffer
impl core::marker::Sync for tst_pipeline::GapBuffer
impl core::marker::Unpin for tst_pipeline::GapBuffer
impl core::marker::UnsafeUnpin for tst_pipeline::GapBuffer
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::GapBuffer
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::GapBuffer
pub struct tst_pipeline::ManagedDemuxReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::new(tst_pipeline::managed_receive::ManagedRecvTransport<R>, tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig) -> Self
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::recv_event(&mut self) -> core::result::Result<core::option::Option<tst_core::mpegts::demux::event::DemuxEvent>, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::stats(&self) -> tst_pipeline::demux_receiver::DemuxReceiverStats
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::with_demux_options(tst_pipeline::managed_receive::ManagedRecvTransport<R>, tst_core::mpegts::demux::types::DemuxerConfig, tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig) -> Self
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::iter::traits::iterator::Iterator for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Item = core::result::Result<tst_core::mpegts::demux::event::DemuxEvent, tst_pipeline::demux_receiver::DemuxReceiverError>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::next(&mut self) -> core::option::Option<Self::Item>
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> !core::marker::Sync for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> core::marker::Unpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
#[non_exhaustive] pub struct tst_pipeline::ManagedDemuxReceiverConfig
impl core::clone::Clone for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::clone(&self) -> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::default::Default for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::default() -> tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::fmt::Debug for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Send for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Sync for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::Unpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiverConfig
pub struct tst_pipeline::ManagedRecvTransport<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::new(R, alloc::boxed::Box<(dyn core::ops::function::FnMut() -> core::result::Result<R, tst_core::transport::TransportError> + core::marker::Send)>, tst_pipeline::reconnect::ReconnectPolicy) -> Self
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
impl<R: tst_core::transport::RecvTransport> tst_core::transport::RecvTransport for tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::close(&mut self)
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::is_alive(&self) -> bool
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::max_payload(&self) -> usize
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::recv_bytes(&mut self, &mut [u8]) -> core::result::Result<usize, tst_core::transport::TransportError>
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl<R> core::marker::Freeze for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> !core::marker::Sync for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> core::marker::Unpin for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::managed_receive::ManagedRecvTransport<R> where R: core::marker::UnsafeUnpin
impl<R> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::managed_receive::ManagedRecvTransport<R>
impl<R> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::managed_receive::ManagedRecvTransport<R>
pub struct tst_pipeline::ManagedTransport<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport + 'static> tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::new<F>(T, F, tst_pipeline::reconnect::ReconnectPolicy) -> Self where F: core::ops::function::Fn() -> core::result::Result<T, tst_core::transport::TransportError> + core::marker::Send + core::marker::Sync + 'static
impl<T: tst_core::transport::Transport + 'static> tst_core::transport::Transport for tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::close(&mut self)
pub fn tst_pipeline::reconnect::ManagedTransport<T>::is_alive(&self) -> bool
pub fn tst_pipeline::reconnect::ManagedTransport<T>::max_payload(&self) -> usize
pub fn tst_pipeline::reconnect::ManagedTransport<T>::send_bytes(&mut self, &[u8]) -> core::result::Result<(), tst_core::transport::TransportError>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
impl<T> core::marker::Freeze for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Send for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Sync for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::Unpin for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedTransport<T>
impl<T> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedTransport<T>
pub struct tst_pipeline::MuxPublisher<P: tst_core::publisher::Publisher>
impl<P: tst_core::publisher::Publisher> tst_pipeline::mux_publisher::MuxPublisher<P>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::cut_segment(&self) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::finish(self) -> core::result::Result<P, tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::publisher_stats(&self) -> tst_core::publisher::PublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_audio(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_data(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_klv(&self, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_subtitle(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::send_video(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::stats(&self) -> tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::with_config(P, tst_core::mpegts::mux::config::MuxerConfig) -> core::result::Result<Self, tst_pipeline::mux_publisher::MuxPublisherError<<P as tst_core::publisher::Publisher>::Error>>
impl<P: tst_core::publisher::Publisher> core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisher<P>
pub fn tst_pipeline::mux_publisher::MuxPublisher<P>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<P> !core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisher<P>
impl<P> core::marker::Send for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Send
impl<P> core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Send
impl<P> core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::Unpin
impl<P> core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisher<P> where P: core::marker::UnsafeUnpin
impl<P> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisher<P>
impl<P> core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisher<P>
#[non_exhaustive] pub struct tst_pipeline::MuxPublisherStats
pub tst_pipeline::MuxPublisherStats::bytes_pushed: u64
pub tst_pipeline::MuxPublisherStats::cut_calls: u64
pub tst_pipeline::MuxPublisherStats::drain_calls: u64
impl core::clone::Clone for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::clone(&self) -> tst_pipeline::mux_publisher::MuxPublisherStats
impl core::default::Default for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::default() -> tst_pipeline::mux_publisher::MuxPublisherStats
impl core::fmt::Debug for tst_pipeline::mux_publisher::MuxPublisherStats
pub fn tst_pipeline::mux_publisher::MuxPublisherStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Freeze for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Send for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Sync for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::Unpin for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::marker::UnsafeUnpin for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_publisher::MuxPublisherStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_publisher::MuxPublisherStats
pub struct tst_pipeline::MuxSender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::audio_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::AudioStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::audio_handles_for_program(&self, u16) -> core::result::Result<alloc::vec::Vec<tst_core::mpegts::mux::types::AudioStreamHandle>, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&self)
pub fn tst_pipeline::mux_sender::MuxSender<T>::data_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::DataStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::mux_sender::MuxSender<T>::klv_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::KlvStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::new(T, tst_core::mpegts::mux::config::MuxerConfig) -> core::result::Result<Self, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::reset_stats(&self)
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_audio(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_audio_to(&self, tst_core::mpegts::mux::types::AudioStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_data(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_data_to(&self, tst_core::mpegts::mux::types::DataStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_klv(&self, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_klv_to(&self, tst_core::mpegts::mux::types::KlvStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, u8) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_subtitle(&self, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_subtitle_to(&self, tst_core::mpegts::mux::types::SubtitleStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_to(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_to_with_dts(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, tst_core::mpegts::common::Pts90khz, bool) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::mux_sender::MuxSender<T>::stats(&self) -> tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSender<T>::stream_codec_stats(&self, u16) -> core::option::Option<tst_core::mpegts::stats::StreamCodecStats>
pub fn tst_pipeline::mux_sender::MuxSender<T>::subtitle_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::SubtitleStreamHandle>
pub fn tst_pipeline::mux_sender::MuxSender<T>::subtitle_handles_for_program(&self, u16) -> core::result::Result<alloc::vec::Vec<tst_core::mpegts::mux::types::SubtitleStreamHandle>, tst_core::error::MuxError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::video_handles(&self) -> alloc::vec::Vec<tst_core::mpegts::mux::types::VideoStreamHandle>
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::mux_sender::MuxSender<T>
pub fn tst_pipeline::mux_sender::MuxSender<T>::drop(&mut self)
impl<T> !core::marker::Freeze for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Send for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Sync for tst_pipeline::mux_sender::MuxSender<T>
impl<T> core::marker::Unpin for tst_pipeline::mux_sender::MuxSender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSender<T> where T: core::marker::UnsafeUnpin
impl<T> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSender<T>
impl<T> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSender<T>
#[non_exhaustive] pub struct tst_pipeline::MuxSenderError
pub tst_pipeline::MuxSenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::MuxSenderError::source: tst_pipeline::mux_sender::MuxSenderErrorSource
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::mux_sender::MuxSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderError
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderError
pub struct tst_pipeline::MuxSenderStats
pub tst_pipeline::MuxSenderStats::bytes_sent: u64
pub tst_pipeline::MuxSenderStats::packets_sent: u64
pub tst_pipeline::MuxSenderStats::pending_bytes_queued: u64
pub tst_pipeline::MuxSenderStats::pending_chunks_queued: u64
pub tst_pipeline::MuxSenderStats::per_stream: alloc::collections::btree::map::BTreeMap<u16, tst_core::mpegts::stats::StreamStats>
pub tst_pipeline::MuxSenderStats::programs_configured: u32
impl core::clone::Clone for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::clone(&self) -> tst_pipeline::mux_sender::MuxSenderStats
impl core::cmp::Eq for tst_pipeline::mux_sender::MuxSenderStats
impl core::cmp::PartialEq for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::eq(&self, &tst_pipeline::mux_sender::MuxSenderStats) -> bool
impl core::default::Default for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::default() -> tst_pipeline::mux_sender::MuxSenderStats
impl core::fmt::Debug for tst_pipeline::mux_sender::MuxSenderStats
pub fn tst_pipeline::mux_sender::MuxSenderStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Freeze for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Send for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Sync for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::Unpin for tst_pipeline::mux_sender::MuxSenderStats
impl core::marker::UnsafeUnpin for tst_pipeline::mux_sender::MuxSenderStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::mux_sender::MuxSenderStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::mux_sender::MuxSenderStats
pub struct tst_pipeline::RawReceiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self)
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::new(R, tst_pipeline::raw_receiver::RawReceiverConfig) -> Self
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::recv_one(&mut self) -> core::result::Result<alloc::vec::Vec<u8>, tst_pipeline::raw_receiver::RawReceiverError>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::stats(&self) -> tst_pipeline::raw_receiver::RawRecvStats
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::raw_receiver::RawReceiver<R>
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::raw_receiver::RawReceiver<R>
impl<R> core::marker::Sync for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiver<R> where R: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::RawReceiverConfig
impl core::clone::Clone for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::clone(&self) -> tst_pipeline::raw_receiver::RawReceiverConfig
impl core::default::Default for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::default() -> tst_pipeline::raw_receiver::RawReceiverConfig
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverConfig
pub fn tst_pipeline::raw_receiver::RawReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverConfig
#[non_exhaustive] pub struct tst_pipeline::RawReceiverError
pub tst_pipeline::RawReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::RawReceiverError::source: tst_pipeline::raw_receiver::RawReceiverErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_receiver::RawReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Send for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Sync for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawReceiverError
pub struct tst_pipeline::RawRecvStats
pub tst_pipeline::RawRecvStats::bytes_received: u64
pub tst_pipeline::RawRecvStats::packets_received: u64
impl core::clone::Clone for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::clone(&self) -> tst_pipeline::raw_receiver::RawRecvStats
impl core::cmp::Eq for tst_pipeline::raw_receiver::RawRecvStats
impl core::cmp::PartialEq for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::eq(&self, &tst_pipeline::raw_receiver::RawRecvStats) -> bool
impl core::default::Default for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::default() -> tst_pipeline::raw_receiver::RawRecvStats
impl core::fmt::Debug for tst_pipeline::raw_receiver::RawRecvStats
pub fn tst_pipeline::raw_receiver::RawRecvStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::StructuralPartialEq for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Freeze for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Send for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Sync for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::Unpin for tst_pipeline::raw_receiver::RawRecvStats
impl core::marker::UnsafeUnpin for tst_pipeline::raw_receiver::RawRecvStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_receiver::RawRecvStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_receiver::RawRecvStats
pub struct tst_pipeline::RawSendStats
pub tst_pipeline::RawSendStats::bytes_sent: u64
pub tst_pipeline::RawSendStats::packets_sent: u64
impl core::clone::Clone for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::clone(&self) -> tst_pipeline::raw_sender::RawSendStats
impl core::cmp::Eq for tst_pipeline::raw_sender::RawSendStats
impl core::cmp::PartialEq for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::eq(&self, &tst_pipeline::raw_sender::RawSendStats) -> bool
impl core::default::Default for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::default() -> tst_pipeline::raw_sender::RawSendStats
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSendStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::raw_sender::RawSendStats
impl core::marker::StructuralPartialEq for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Send for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Sync for tst_pipeline::raw_sender::RawSendStats
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSendStats
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSendStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSendStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSendStats
pub struct tst_pipeline::RawSender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self)
pub fn tst_pipeline::raw_sender::RawSender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::raw_sender::RawSender<T>::new(T, tst_pipeline::raw_sender::RawSenderConfig) -> Self
pub fn tst_pipeline::raw_sender::RawSender<T>::reset_stats(&mut self)
pub fn tst_pipeline::raw_sender::RawSender<T>::send(&mut self, &[u8]) -> core::result::Result<(), tst_pipeline::raw_sender::RawSenderError>
pub fn tst_pipeline::raw_sender::RawSender<T>::stats(&self) -> tst_pipeline::raw_sender::RawSendStats
pub fn tst_pipeline::raw_sender::RawSender<T>::transport(&self) -> &T
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::raw_sender::RawSender<T>
pub fn tst_pipeline::raw_sender::RawSender<T>::drop(&mut self)
impl<T> core::marker::Freeze for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::raw_sender::RawSender<T>
impl<T> core::marker::Sync for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSender<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSender<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSender<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::RawSenderConfig
impl core::clone::Clone for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::clone(&self) -> tst_pipeline::raw_sender::RawSenderConfig
impl core::default::Default for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::default() -> tst_pipeline::raw_sender::RawSenderConfig
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderConfig
pub fn tst_pipeline::raw_sender::RawSenderConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderConfig
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderConfig
#[non_exhaustive] pub struct tst_pipeline::RawSenderError
pub tst_pipeline::RawSenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::RawSenderError::source: tst_pipeline::raw_sender::RawSenderErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_sender::RawSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Send for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Sync for tst_pipeline::raw_sender::RawSenderError
impl core::marker::Unpin for tst_pipeline::raw_sender::RawSenderError
impl core::marker::UnsafeUnpin for tst_pipeline::raw_sender::RawSenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::raw_sender::RawSenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::raw_sender::RawSenderError
pub struct tst_pipeline::Receiver<R: tst_core::transport::RecvTransport>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::is_alive(&self) -> bool
pub fn tst_pipeline::receiver::Receiver<R>::new(R, tst_pipeline::receiver::ReceiverConfig) -> Self
pub fn tst_pipeline::receiver::Receiver<R>::next_packet(&mut self) -> core::result::Result<[u8; 188], tst_pipeline::receiver::ReceiverError>
pub fn tst_pipeline::receiver::Receiver<R>::reset_stats(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::reset_sync(&mut self)
pub fn tst_pipeline::receiver::Receiver<R>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::receiver::Receiver<R>::stats(&self) -> tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::Receiver<R>::transport(&self) -> &R
impl<R: tst_core::transport::RecvTransport> core::fmt::Debug for tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<R: tst_core::transport::RecvTransport> core::ops::drop::Drop for tst_pipeline::receiver::Receiver<R>
pub fn tst_pipeline::receiver::Receiver<R>::drop(&mut self)
impl<R> core::marker::Freeze for tst_pipeline::receiver::Receiver<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::receiver::Receiver<R>
impl<R> core::marker::Sync for tst_pipeline::receiver::Receiver<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::receiver::Receiver<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::receiver::Receiver<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::Receiver<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::Receiver<R> where R: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::ReceiverConfig
impl core::clone::Clone for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::clone(&self) -> tst_pipeline::receiver::ReceiverConfig
impl core::default::Default for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::default() -> tst_pipeline::receiver::ReceiverConfig
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverConfig
pub fn tst_pipeline::receiver::ReceiverConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Send for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Sync for tst_pipeline::receiver::ReceiverConfig
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverConfig
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverConfig
#[non_exhaustive] pub struct tst_pipeline::ReceiverError
pub tst_pipeline::ReceiverError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::ReceiverError::source: tst_pipeline::receiver::ReceiverErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::from(tst_core::transport::TransportError) -> Self
impl core::error::Error for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::receiver::ReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverError
impl core::marker::Send for tst_pipeline::receiver::ReceiverError
impl core::marker::Sync for tst_pipeline::receiver::ReceiverError
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverError
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverError
pub struct tst_pipeline::ReceiverStats
pub tst_pipeline::ReceiverStats::bytes_received: u64
pub tst_pipeline::ReceiverStats::bytes_skipped_for_sync: u64
pub tst_pipeline::ReceiverStats::packets_received: u64
pub tst_pipeline::ReceiverStats::resync_events: u64
impl core::clone::Clone for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::clone(&self) -> tst_pipeline::receiver::ReceiverStats
impl core::cmp::Eq for tst_pipeline::receiver::ReceiverStats
impl core::cmp::PartialEq for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::eq(&self, &tst_pipeline::receiver::ReceiverStats) -> bool
impl core::default::Default for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::default() -> tst_pipeline::receiver::ReceiverStats
impl core::fmt::Debug for tst_pipeline::receiver::ReceiverStats
pub fn tst_pipeline::receiver::ReceiverStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::receiver::ReceiverStats
impl core::marker::StructuralPartialEq for tst_pipeline::receiver::ReceiverStats
impl core::marker::Freeze for tst_pipeline::receiver::ReceiverStats
impl core::marker::Send for tst_pipeline::receiver::ReceiverStats
impl core::marker::Sync for tst_pipeline::receiver::ReceiverStats
impl core::marker::Unpin for tst_pipeline::receiver::ReceiverStats
impl core::marker::UnsafeUnpin for tst_pipeline::receiver::ReceiverStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::receiver::ReceiverStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::receiver::ReceiverStats
pub struct tst_pipeline::ReconnectPolicy
pub tst_pipeline::ReconnectPolicy::backoff: tst_pipeline::reconnect::BackoffStrategy
pub tst_pipeline::ReconnectPolicy::gap_buffer_capacity: usize
pub tst_pipeline::ReconnectPolicy::max_attempts: core::option::Option<u32>
pub tst_pipeline::ReconnectPolicy::overflow_policy: tst_pipeline::OverflowPolicy
impl tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::next_delay(&self, u32) -> core::option::Option<core::time::Duration>
impl core::clone::Clone for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::clone(&self) -> tst_pipeline::reconnect::ReconnectPolicy
impl core::default::Default for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::default() -> Self
impl core::fmt::Debug for tst_pipeline::reconnect::ReconnectPolicy
pub fn tst_pipeline::reconnect::ReconnectPolicy::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Send for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Sync for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::Unpin for tst_pipeline::reconnect::ReconnectPolicy
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ReconnectPolicy
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ReconnectPolicy
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ReconnectPolicy
pub struct tst_pipeline::Sender<T: tst_core::transport::Transport>
impl<T: tst_core::transport::Transport> tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::cancel_handle(&self) -> core::option::Option<alloc::sync::Arc<(dyn tst_core::transport::TransportCancel + core::marker::Send + core::marker::Sync)>>
pub fn tst_pipeline::sender::Sender<T>::close(&mut self)
pub fn tst_pipeline::sender::Sender<T>::flush(&mut self) -> core::result::Result<(), tst_pipeline::sender::SenderError>
pub fn tst_pipeline::sender::Sender<T>::is_alive(&self) -> bool
pub fn tst_pipeline::sender::Sender<T>::new(T, tst_pipeline::sender::SenderConfig) -> Self
pub fn tst_pipeline::sender::Sender<T>::reset_stats(&mut self)
pub fn tst_pipeline::sender::Sender<T>::send_ts(&mut self, &[u8]) -> core::result::Result<(), tst_pipeline::sender::SenderError>
pub fn tst_pipeline::sender::Sender<T>::socket_stats(&self) -> core::option::Option<tst_core::transport::SocketStats>
pub fn tst_pipeline::sender::Sender<T>::stats(&self) -> tst_pipeline::SenderStats
pub fn tst_pipeline::sender::Sender<T>::transport(&self) -> &T
impl<T: tst_core::transport::Transport> core::fmt::Debug for tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<T: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::sender::Sender<T>
pub fn tst_pipeline::sender::Sender<T>::drop(&mut self)
impl<T> core::marker::Freeze for tst_pipeline::sender::Sender<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::sender::Sender<T>
impl<T> core::marker::Sync for tst_pipeline::sender::Sender<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::sender::Sender<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::sender::Sender<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::Sender<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::Sender<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub struct tst_pipeline::SenderConfig
pub tst_pipeline::SenderConfig::framing_mode: tst_pipeline::TsFramingMode
pub tst_pipeline::SenderConfig::max_unsynced_bytes: usize
impl core::clone::Clone for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::clone(&self) -> tst_pipeline::sender::SenderConfig
impl core::default::Default for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::default() -> Self
impl core::fmt::Debug for tst_pipeline::sender::SenderConfig
pub fn tst_pipeline::sender::SenderConfig::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::sender::SenderConfig
impl core::marker::Send for tst_pipeline::sender::SenderConfig
impl core::marker::Sync for tst_pipeline::sender::SenderConfig
impl core::marker::Unpin for tst_pipeline::sender::SenderConfig
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderConfig
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderConfig
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderConfig
#[non_exhaustive] pub struct tst_pipeline::SenderError
pub tst_pipeline::SenderError::kind: tst_pipeline::shell_error::ShellErrorKind
pub tst_pipeline::SenderError::source: tst_pipeline::sender::SenderErrorSource
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::source(&self) -> core::option::Option<&(dyn core::error::Error + 'static)>
impl core::fmt::Debug for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_pipeline::shell_error::ShellError for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::sender::SenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl core::marker::Freeze for tst_pipeline::sender::SenderError
impl core::marker::Send for tst_pipeline::sender::SenderError
impl core::marker::Sync for tst_pipeline::sender::SenderError
impl core::marker::Unpin for tst_pipeline::sender::SenderError
impl core::marker::UnsafeUnpin for tst_pipeline::sender::SenderError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::sender::SenderError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::sender::SenderError
pub struct tst_pipeline::SenderStats
pub tst_pipeline::SenderStats::bytes_pushed: u64
pub tst_pipeline::SenderStats::bytes_skipped_for_sync: u64
pub tst_pipeline::SenderStats::packets_sent: u64
pub tst_pipeline::SenderStats::resync_events: u64
impl core::clone::Clone for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::clone(&self) -> tst_pipeline::SenderStats
impl core::cmp::Eq for tst_pipeline::SenderStats
impl core::cmp::PartialEq for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::eq(&self, &tst_pipeline::SenderStats) -> bool
impl core::default::Default for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::default() -> tst_pipeline::SenderStats
impl core::fmt::Debug for tst_pipeline::SenderStats
pub fn tst_pipeline::SenderStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::SenderStats
impl core::marker::Freeze for tst_pipeline::SenderStats
impl core::marker::Send for tst_pipeline::SenderStats
impl core::marker::Sync for tst_pipeline::SenderStats
impl core::marker::Unpin for tst_pipeline::SenderStats
impl core::marker::UnsafeUnpin for tst_pipeline::SenderStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::SenderStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::SenderStats
pub trait tst_pipeline::ShellError: core::error::Error
pub fn tst_pipeline::ShellError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::ShellError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::demux_receiver::DemuxReceiverError
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::demux_receiver::DemuxReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::mux_sender::MuxSenderError
pub fn tst_pipeline::mux_sender::MuxSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::mux_sender::MuxSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_receiver::RawReceiverError
pub fn tst_pipeline::raw_receiver::RawReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_receiver::RawReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::raw_sender::RawSenderError
pub fn tst_pipeline::raw_sender::RawSenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::raw_sender::RawSenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::receiver::ReceiverError
pub fn tst_pipeline::receiver::ReceiverError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::receiver::ReceiverError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
impl tst_pipeline::shell_error::ShellError for tst_pipeline::sender::SenderError
pub fn tst_pipeline::sender::SenderError::errno_code(&self) -> core::option::Option<i32>
pub fn tst_pipeline::sender::SenderError::kind(&self) -> tst_pipeline::shell_error::ShellErrorKind
pub type tst_pipeline::BoxedDemuxReceiver = tst_pipeline::demux_receiver::DemuxReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::BoxedMuxSender = tst_pipeline::mux_sender::MuxSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub type tst_pipeline::BoxedRawReceiver = tst_pipeline::raw_receiver::RawReceiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::BoxedRawSender = tst_pipeline::raw_sender::RawSender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub type tst_pipeline::BoxedReceiver = tst_pipeline::receiver::Receiver<alloc::boxed::Box<dyn tst_core::transport::RecvTransport>>
pub type tst_pipeline::BoxedSender = tst_pipeline::sender::Sender<alloc::boxed::Box<dyn tst_core::transport::Transport>>
pub type tst_pipeline::ByteSink = alloc::boxed::Box<(dyn core::ops::function::FnMut(&[u8]) + core::marker::Send)>
