pub mod tst_pipeline
pub use tst_pipeline::BrokenCause
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::binding
pub mod tst_pipeline::binding::handles
pub struct tst_pipeline::binding::handles::ManagedHandles
pub tst_pipeline::binding::handles::ManagedHandles::attempts: alloc::sync::Arc<core::sync::atomic::AtomicU64>
pub tst_pipeline::binding::handles::ManagedHandles::cancel: alloc::sync::Arc<dyn tst_core::transport::TransportCancel>
pub tst_pipeline::binding::handles::ManagedHandles::end_reason: tst_pipeline::RecvEndReasonHandle
pub tst_pipeline::binding::handles::ManagedHandles::reconnecting: alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub tst_pipeline::binding::handles::ManagedHandles::reconnects: alloc::sync::Arc<core::sync::atomic::AtomicU64>
impl core::clone::Clone for tst_pipeline::binding::handles::ManagedHandles
pub fn tst_pipeline::binding::handles::ManagedHandles::clone(&self) -> tst_pipeline::binding::handles::ManagedHandles
impl core::fmt::Debug for tst_pipeline::binding::handles::ManagedHandles
pub fn tst_pipeline::binding::handles::ManagedHandles::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Send for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Sync for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Unpin for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::UnsafeUnpin for tst_pipeline::binding::handles::ManagedHandles
impl !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::handles::ManagedHandles
impl !core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::handles::ManagedHandles
pub mod tst_pipeline::binding::kind
#[non_exhaustive] #[repr(i32)] pub enum tst_pipeline::binding::kind::BindingErrorKind
pub tst_pipeline::binding::kind::BindingErrorKind::Backpressure = -4
pub tst_pipeline::binding::kind::BindingErrorKind::Broken = -8
pub tst_pipeline::binding::kind::BindingErrorKind::Closed = -7
pub tst_pipeline::binding::kind::BindingErrorKind::CodecBadSyncWord = -99
pub tst_pipeline::binding::kind::BindingErrorKind::CodecBufferTooSmall = -105
pub tst_pipeline::binding::kind::BindingErrorKind::CodecDanglingSpsReference = -95
pub tst_pipeline::binding::kind::BindingErrorKind::CodecDanglingVpsReference = -96
pub tst_pipeline::binding::kind::BindingErrorKind::CodecEngineError = -97
pub tst_pipeline::binding::kind::BindingErrorKind::CodecForbidden = -101
pub tst_pipeline::binding::kind::BindingErrorKind::CodecInvalidGolomb = -92
pub tst_pipeline::binding::kind::BindingErrorKind::CodecInvalidLeb128 = -98
pub tst_pipeline::binding::kind::BindingErrorKind::CodecInvalidLengthSize = -103
pub tst_pipeline::binding::kind::BindingErrorKind::CodecNalLengthOverflow = -104
pub tst_pipeline::binding::kind::BindingErrorKind::CodecReservedValue = -93
pub tst_pipeline::binding::kind::BindingErrorKind::CodecTruncated = -100
pub tst_pipeline::binding::kind::BindingErrorKind::CodecTruncatedRbsp = -91
pub tst_pipeline::binding::kind::BindingErrorKind::CodecUnsupportedFreeFormat = -102
pub tst_pipeline::binding::kind::BindingErrorKind::CodecUnsupportedProfile = -94
pub tst_pipeline::binding::kind::BindingErrorKind::ConfigInvalid = -1
pub tst_pipeline::binding::kind::BindingErrorKind::DemuxMalformedPes = -72
pub tst_pipeline::binding::kind::BindingErrorKind::DemuxMalformedPsi = -71
pub tst_pipeline::binding::kind::BindingErrorKind::DemuxStrictRejection = -70
pub tst_pipeline::binding::kind::BindingErrorKind::DemuxSyncBufExhausted = -73
pub tst_pipeline::binding::kind::BindingErrorKind::DemuxUnrecoverable = -69
pub tst_pipeline::binding::kind::BindingErrorKind::EndOfStream = -12
pub tst_pipeline::binding::kind::BindingErrorKind::HlsBindFailed = -57
pub tst_pipeline::binding::kind::BindingErrorKind::HlsFinished = -36
pub tst_pipeline::binding::kind::BindingErrorKind::HlsInvalidConfig = -35
pub tst_pipeline::binding::kind::BindingErrorKind::HlsIo = -34
pub tst_pipeline::binding::kind::BindingErrorKind::HlsTls = -37
pub tst_pipeline::binding::kind::BindingErrorKind::HlsTlsDisabled = -59
pub tst_pipeline::binding::kind::BindingErrorKind::HlsUnalignedPushTs = -58
pub tst_pipeline::binding::kind::BindingErrorKind::HlsUrl = -56
pub tst_pipeline::binding::kind::BindingErrorKind::InputMalformed = -3
pub tst_pipeline::binding::kind::BindingErrorKind::Internal = -10
pub tst_pipeline::binding::kind::BindingErrorKind::InvalidAv1Obu = -44
pub tst_pipeline::binding::kind::BindingErrorKind::InvalidNal = -2
pub tst_pipeline::binding::kind::BindingErrorKind::InvalidUsage = -9
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeBadUniversalLabel = -75
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeChecksumMismatch = -76
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeDuplicateTag = -77
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeMalformedBytes = -79
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeMissingRequiredTag = -78
pub tst_pipeline::binding::kind::BindingErrorKind::KlvDecodeTruncatedSet = -74
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeBufferTooSmall = -80
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeDuplicateTargetId = -89
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeForbiddenStandaloneOffset = -90
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeInvalidImapbParams = -85
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeMissingMandatoryItem = -86
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeOutOfRange = -82
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeRecordTooLarge = -81
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeReservedTagInUnknown = -87
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeStringTooLong = -83
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeUnsupportedImapbLength = -84
pub tst_pipeline::binding::kind::BindingErrorKind::KlvEncodeVTargetPackEmpty = -88
pub tst_pipeline::binding::kind::BindingErrorKind::KlvTooLarge = -5
pub tst_pipeline::binding::kind::BindingErrorKind::MispTime = -45
pub tst_pipeline::binding::kind::BindingErrorKind::MispTimeMalformed = -46
pub tst_pipeline::binding::kind::BindingErrorKind::NotAvailable = -13
pub tst_pipeline::binding::kind::BindingErrorKind::NotFound = -14
pub tst_pipeline::binding::kind::BindingErrorKind::PanicCaught = -11
pub tst_pipeline::binding::kind::BindingErrorKind::RistContextCreateFailed = -61
pub tst_pipeline::binding::kind::BindingErrorKind::RistEncryptionDisabled = -41
pub tst_pipeline::binding::kind::BindingErrorKind::RistFfi = -38
pub tst_pipeline::binding::kind::BindingErrorKind::RistInvalidConfig = -39
pub tst_pipeline::binding::kind::BindingErrorKind::RistPeerCreateFailed = -62
pub tst_pipeline::binding::kind::BindingErrorKind::RistUrl = -60
pub tst_pipeline::binding::kind::BindingErrorKind::RtpHostNotLiteral = -66
pub tst_pipeline::binding::kind::BindingErrorKind::RtpIfaceUnsupported = -68
pub tst_pipeline::binding::kind::BindingErrorKind::RtpIo = -67
pub tst_pipeline::binding::kind::BindingErrorKind::RtpMissingPayloadTypeParam = -64
pub tst_pipeline::binding::kind::BindingErrorKind::RtpPayloadTypeParam = -63
pub tst_pipeline::binding::kind::BindingErrorKind::RtpUrl = -65
pub tst_pipeline::binding::kind::BindingErrorKind::RtspAuthFailed = -17
pub tst_pipeline::binding::kind::BindingErrorKind::RtspAuthRequired = -18
pub tst_pipeline::binding::kind::BindingErrorKind::RtspIo = -22
pub tst_pipeline::binding::kind::BindingErrorKind::RtspMount = -25
pub tst_pipeline::binding::kind::BindingErrorKind::RtspNotFound = -19
pub tst_pipeline::binding::kind::BindingErrorKind::RtspProtocol = -16
pub tst_pipeline::binding::kind::BindingErrorKind::RtspServer = -24
pub tst_pipeline::binding::kind::BindingErrorKind::RtspTimeout = -23
pub tst_pipeline::binding::kind::BindingErrorKind::RtspTls = -21
pub tst_pipeline::binding::kind::BindingErrorKind::RtspUnsupportedTransport = -20
pub tst_pipeline::binding::kind::BindingErrorKind::SrtAcceptFailed = -50
pub tst_pipeline::binding::kind::BindingErrorKind::SrtConnectFailed = -49
pub tst_pipeline::binding::kind::BindingErrorKind::SrtIo = -52
pub tst_pipeline::binding::kind::BindingErrorKind::SrtTimeout = -51
pub tst_pipeline::binding::kind::BindingErrorKind::TcpConnectTimeout = -32
pub tst_pipeline::binding::kind::BindingErrorKind::TcpInvalidConfig = -31
pub tst_pipeline::binding::kind::BindingErrorKind::TcpIo = -30
pub tst_pipeline::binding::kind::BindingErrorKind::TcpTls = -33
pub tst_pipeline::binding::kind::BindingErrorKind::TcpTlsDisabled = -55
pub tst_pipeline::binding::kind::BindingErrorKind::TcpUrl = -54
pub tst_pipeline::binding::kind::BindingErrorKind::TooLarge = -6
pub tst_pipeline::binding::kind::BindingErrorKind::UdpInvalidConfig = -27
pub tst_pipeline::binding::kind::BindingErrorKind::UdpIo = -26
pub tst_pipeline::binding::kind::BindingErrorKind::UdpUrl = -53
pub tst_pipeline::binding::kind::BindingErrorKind::WrongType = -47
impl tst_pipeline::binding::kind::BindingErrorKind
pub const tst_pipeline::binding::kind::BindingErrorKind::ALL: &'static [tst_pipeline::binding::kind::BindingErrorKind]
pub fn tst_pipeline::binding::kind::BindingErrorKind::c_projection(&self) -> i32
pub fn tst_pipeline::binding::kind::BindingErrorKind::name(&self) -> &'static str
pub fn tst_pipeline::binding::kind::BindingErrorKind::variant_name(&self) -> &'static str
impl tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::c_code(&self) -> i32
pub fn tst_pipeline::binding::kind::BindingErrorKind::is_c_frozen(&self) -> bool
impl core::clone::Clone for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::clone(&self) -> tst_pipeline::binding::kind::BindingErrorKind
impl core::cmp::Eq for tst_pipeline::binding::kind::BindingErrorKind
impl core::cmp::PartialEq for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::eq(&self, &tst_pipeline::binding::kind::BindingErrorKind) -> bool
impl core::convert::From<tst_pipeline::shell_error::ShellErrorKind> for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::from(tst_pipeline::shell_error::ShellErrorKind) -> Self
impl core::fmt::Debug for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::StructuralPartialEq for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Freeze for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Send for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Sync for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Unpin for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::UnsafeUnpin for tst_pipeline::binding::kind::BindingErrorKind
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::kind::BindingErrorKind
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::kind::BindingErrorKind
pub struct tst_pipeline::binding::kind::BindingError
pub tst_pipeline::binding::kind::BindingError::detail: alloc::string::String
pub tst_pipeline::binding::kind::BindingError::kind: tst_pipeline::binding::kind::BindingErrorKind
impl tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::new(tst_pipeline::binding::kind::BindingErrorKind, impl core::convert::Into<alloc::string::String>) -> Self
impl core::clone::Clone for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::clone(&self) -> tst_pipeline::binding::kind::BindingError
impl core::cmp::Eq for tst_pipeline::binding::kind::BindingError
impl core::cmp::PartialEq for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::eq(&self, &tst_pipeline::binding::kind::BindingError) -> bool
impl core::convert::From<tst_core::codec::CodecParseError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::codec::CodecParseError) -> Self
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::error::KlvDecodeError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvDecodeError) -> Self
impl core::convert::From<tst_core::error::KlvEncodeError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvEncodeError) -> Self
impl core::convert::From<tst_core::error::KlvFieldError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvFieldError) -> Self
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::binding::owned::HandleState> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::HandleState) -> Self
impl core::convert::From<tst_pipeline::demux_receiver::DemuxReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::demux_receiver::DemuxReceiverError) -> Self
impl core::convert::From<tst_pipeline::mux_sender::MuxSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_sender::MuxSenderError) -> Self
impl core::convert::From<tst_pipeline::raw_receiver::RawReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_receiver::RawReceiverError) -> Self
impl core::convert::From<tst_pipeline::raw_sender::RawSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_sender::RawSenderError) -> Self
impl core::convert::From<tst_pipeline::receiver::ReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::receiver::ReceiverError) -> Self
impl core::convert::From<tst_pipeline::sender::SenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::SenderError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::binding::kind::BindingError
impl core::fmt::Debug for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::binding::kind::BindingError
impl<E: core::fmt::Display> core::convert::From<tst_pipeline::binding::owned::CloseFailure<E>> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::CloseFailure<E>) -> Self
impl<E> core::convert::From<tst_pipeline::mux_publisher::MuxPublisherError<E>> for tst_pipeline::binding::kind::BindingError where E: core::convert::Into<tst_pipeline::binding::kind::BindingError> + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_publisher::MuxPublisherError<E>) -> Self
impl core::marker::Freeze for tst_pipeline::binding::kind::BindingError
impl core::marker::Send for tst_pipeline::binding::kind::BindingError
impl core::marker::Sync for tst_pipeline::binding::kind::BindingError
impl core::marker::Unpin for tst_pipeline::binding::kind::BindingError
impl core::marker::UnsafeUnpin for tst_pipeline::binding::kind::BindingError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::kind::BindingError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::kind_of_codec(&tst_core::codec::CodecParseError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_demux(&tst_core::error::DemuxError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_klv_decode(&tst_core::error::KlvDecodeError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_klv_encode(&tst_core::error::KlvEncodeError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_klv_field(&tst_core::error::KlvFieldError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_mux(&tst_core::error::MuxError) -> tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::kind_of_transport(&tst_core::transport::TransportError) -> tst_pipeline::binding::kind::BindingErrorKind
pub mod tst_pipeline::binding::owned
pub enum tst_pipeline::binding::owned::CloseFailure<E>
pub tst_pipeline::binding::owned::CloseFailure::Inner(E)
pub tst_pipeline::binding::owned::CloseFailure::Panicked
pub tst_pipeline::binding::owned::CloseFailure::Panicked::detail: alloc::string::String
impl<E: core::fmt::Debug> core::fmt::Debug for tst_pipeline::binding::owned::CloseFailure<E>
pub fn tst_pipeline::binding::owned::CloseFailure<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E: core::fmt::Display> core::convert::From<tst_pipeline::binding::owned::CloseFailure<E>> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::CloseFailure<E>) -> Self
impl<E> core::marker::Freeze for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Freeze
impl<E> core::marker::Send for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Send
impl<E> core::marker::Sync for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Sync
impl<E> core::marker::Unpin for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Unpin
impl<E> core::marker::UnsafeUnpin for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::UnsafeUnpin
impl<E> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::CloseFailure<E> where E: core::panic::unwind_safe::RefUnwindSafe
impl<E> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::CloseFailure<E> where E: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub enum tst_pipeline::binding::owned::HandleState
pub tst_pipeline::binding::owned::HandleState::Closed
pub tst_pipeline::binding::owned::HandleState::Panicked
pub tst_pipeline::binding::owned::HandleState::Panicked::detail: alloc::string::String
pub tst_pipeline::binding::owned::HandleState::Poisoned
impl core::clone::Clone for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::clone(&self) -> tst_pipeline::binding::owned::HandleState
impl core::cmp::Eq for tst_pipeline::binding::owned::HandleState
impl core::cmp::PartialEq for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::eq(&self, &tst_pipeline::binding::owned::HandleState) -> bool
impl core::convert::From<tst_pipeline::binding::owned::HandleState> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::HandleState) -> Self
impl core::fmt::Debug for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::binding::owned::HandleState
impl core::marker::Freeze for tst_pipeline::binding::owned::HandleState
impl core::marker::Send for tst_pipeline::binding::owned::HandleState
impl core::marker::Sync for tst_pipeline::binding::owned::HandleState
impl core::marker::Unpin for tst_pipeline::binding::owned::HandleState
impl core::marker::UnsafeUnpin for tst_pipeline::binding::owned::HandleState
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::HandleState
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::HandleState
pub struct tst_pipeline::binding::owned::FlagCancel(_)
impl tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::is_set(&self) -> bool
pub fn tst_pipeline::binding::owned::FlagCancel::new() -> Self
impl core::default::Default for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::default() -> tst_pipeline::binding::owned::FlagCancel
impl core::fmt::Debug for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_core::transport::TransportCancel for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::cancel(&self)
pub fn tst_pipeline::binding::owned::FlagCancel::is_cancelled(&self) -> bool
impl !core::marker::Freeze for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Send for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Sync for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Unpin for tst_pipeline::binding::owned::FlagCancel
impl core::marker::UnsafeUnpin for tst_pipeline::binding::owned::FlagCancel
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::FlagCancel
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::FlagCancel
pub struct tst_pipeline::binding::owned::Owned<T, S>
impl<T, S> tst_pipeline::binding::owned::Owned<T, S>
pub fn tst_pipeline::binding::owned::Owned<T, S>::cancel(&self)
pub fn tst_pipeline::binding::owned::Owned<T, S>::cancel_arc(&self) -> alloc::sync::Arc<dyn tst_core::transport::TransportCancel>
pub fn tst_pipeline::binding::owned::Owned<T, S>::end_reason(&self) -> core::option::Option<tst_pipeline::RecvEndReason>
pub fn tst_pipeline::binding::owned::Owned<T, S>::is_cancelled(&self) -> bool
pub fn tst_pipeline::binding::owned::Owned<T, S>::is_closed(&self) -> bool
pub fn tst_pipeline::binding::owned::Owned<T, S>::new(T, alloc::sync::Arc<dyn tst_core::transport::TransportCancel>, S) -> Self
pub fn tst_pipeline::binding::owned::Owned<T, S>::snapshot(&self) -> &S
pub fn tst_pipeline::binding::owned::Owned<T, S>::take(&self) -> core::option::Option<T>
pub fn tst_pipeline::binding::owned::Owned<T, S>::try_with_ref<R>(&self, impl core::ops::function::FnOnce(&T) -> R) -> core::option::Option<core::result::Result<R, tst_pipeline::binding::owned::HandleState>>
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_end_reason(self, tst_pipeline::RecvEndReasonHandle) -> Self
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_mut<R>(&self, impl core::ops::function::FnOnce(&mut T) -> R) -> core::result::Result<R, tst_pipeline::binding::owned::HandleState>
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_ref<R>(&self, impl core::ops::function::FnOnce(&T) -> R) -> core::result::Result<R, tst_pipeline::binding::owned::HandleState>
impl<T: tst_pipeline::binding::owned::Close, S> tst_pipeline::binding::owned::Owned<T, S>
pub fn tst_pipeline::binding::owned::Owned<T, S>::close(&self) -> core::result::Result<(), tst_pipeline::binding::owned::CloseFailure<<T as tst_pipeline::binding::owned::Close>::Error>>
impl<T, S> !core::marker::Freeze for tst_pipeline::binding::owned::Owned<T, S>
impl<T, S> core::marker::Send for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Send, T: core::marker::Send
impl<T, S> core::marker::Sync for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Sync, T: core::marker::Send
impl<T, S> core::marker::Unpin for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Unpin, T: core::marker::Unpin
impl<T, S> core::marker::UnsafeUnpin for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::UnsafeUnpin, T: core::marker::UnsafeUnpin
impl<T, S> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::Owned<T, S>
impl<T, S> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::Owned<T, S>
pub trait tst_pipeline::binding::owned::Close
pub type tst_pipeline::binding::owned::Close::Error: core::fmt::Debug + core::fmt::Display
pub fn tst_pipeline::binding::owned::Close::close(&mut self) -> core::result::Result<(), Self::Error>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::RecvHalf<R>
pub type tst_pipeline::binding::shells::RecvHalf<R>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::RecvHalf<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_receiver::RawReceiver<R>
pub type tst_pipeline::raw_receiver::RawReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::receiver::Receiver<R>
pub type tst_pipeline::receiver::Receiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::SendHalf<T>
pub type tst_pipeline::binding::shells::SendHalf<T>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::SendHalf<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::mux_sender::MuxSender<T>
pub type tst_pipeline::mux_sender::MuxSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_sender::RawSender<T>
pub type tst_pipeline::raw_sender::RawSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::sender::Sender<T>
pub type tst_pipeline::sender::Sender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::sender::Sender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
pub mod tst_pipeline::binding::panic
pub fn tst_pipeline::binding::panic::catch<R>(impl core::ops::function::FnOnce() -> R) -> core::result::Result<R, alloc::string::String>
pub fn tst_pipeline::binding::panic::payload_message(&(dyn core::any::Any + core::marker::Send)) -> alloc::string::String
pub mod tst_pipeline::binding::shells
pub struct tst_pipeline::binding::shells::RecvHalf<R>(pub R)
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::RecvHalf<R>
pub type tst_pipeline::binding::shells::RecvHalf<R>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::RecvHalf<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R> core::marker::Freeze for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Send
impl<R> core::marker::Sync for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::shells::RecvHalf<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::shells::RecvHalf<R> where R: core::panic::unwind_safe::UnwindSafe
pub struct tst_pipeline::binding::shells::SendHalf<T>(pub T)
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::SendHalf<T>
pub type tst_pipeline::binding::shells::SendHalf<T>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::SendHalf<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T> core::marker::Freeze for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Send
impl<T> core::marker::Sync for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::shells::SendHalf<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::shells::SendHalf<T> where T: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] #[repr(i32)] pub enum tst_pipeline::binding::BindingErrorKind
pub tst_pipeline::binding::BindingErrorKind::Backpressure = -4
pub tst_pipeline::binding::BindingErrorKind::Broken = -8
pub tst_pipeline::binding::BindingErrorKind::Closed = -7
pub tst_pipeline::binding::BindingErrorKind::CodecBadSyncWord = -99
pub tst_pipeline::binding::BindingErrorKind::CodecBufferTooSmall = -105
pub tst_pipeline::binding::BindingErrorKind::CodecDanglingSpsReference = -95
pub tst_pipeline::binding::BindingErrorKind::CodecDanglingVpsReference = -96
pub tst_pipeline::binding::BindingErrorKind::CodecEngineError = -97
pub tst_pipeline::binding::BindingErrorKind::CodecForbidden = -101
pub tst_pipeline::binding::BindingErrorKind::CodecInvalidGolomb = -92
pub tst_pipeline::binding::BindingErrorKind::CodecInvalidLeb128 = -98
pub tst_pipeline::binding::BindingErrorKind::CodecInvalidLengthSize = -103
pub tst_pipeline::binding::BindingErrorKind::CodecNalLengthOverflow = -104
pub tst_pipeline::binding::BindingErrorKind::CodecReservedValue = -93
pub tst_pipeline::binding::BindingErrorKind::CodecTruncated = -100
pub tst_pipeline::binding::BindingErrorKind::CodecTruncatedRbsp = -91
pub tst_pipeline::binding::BindingErrorKind::CodecUnsupportedFreeFormat = -102
pub tst_pipeline::binding::BindingErrorKind::CodecUnsupportedProfile = -94
pub tst_pipeline::binding::BindingErrorKind::ConfigInvalid = -1
pub tst_pipeline::binding::BindingErrorKind::DemuxMalformedPes = -72
pub tst_pipeline::binding::BindingErrorKind::DemuxMalformedPsi = -71
pub tst_pipeline::binding::BindingErrorKind::DemuxStrictRejection = -70
pub tst_pipeline::binding::BindingErrorKind::DemuxSyncBufExhausted = -73
pub tst_pipeline::binding::BindingErrorKind::DemuxUnrecoverable = -69
pub tst_pipeline::binding::BindingErrorKind::EndOfStream = -12
pub tst_pipeline::binding::BindingErrorKind::HlsBindFailed = -57
pub tst_pipeline::binding::BindingErrorKind::HlsFinished = -36
pub tst_pipeline::binding::BindingErrorKind::HlsInvalidConfig = -35
pub tst_pipeline::binding::BindingErrorKind::HlsIo = -34
pub tst_pipeline::binding::BindingErrorKind::HlsTls = -37
pub tst_pipeline::binding::BindingErrorKind::HlsTlsDisabled = -59
pub tst_pipeline::binding::BindingErrorKind::HlsUnalignedPushTs = -58
pub tst_pipeline::binding::BindingErrorKind::HlsUrl = -56
pub tst_pipeline::binding::BindingErrorKind::InputMalformed = -3
pub tst_pipeline::binding::BindingErrorKind::Internal = -10
pub tst_pipeline::binding::BindingErrorKind::InvalidAv1Obu = -44
pub tst_pipeline::binding::BindingErrorKind::InvalidNal = -2
pub tst_pipeline::binding::BindingErrorKind::InvalidUsage = -9
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeBadUniversalLabel = -75
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeChecksumMismatch = -76
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeDuplicateTag = -77
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeMalformedBytes = -79
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeMissingRequiredTag = -78
pub tst_pipeline::binding::BindingErrorKind::KlvDecodeTruncatedSet = -74
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeBufferTooSmall = -80
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeDuplicateTargetId = -89
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeForbiddenStandaloneOffset = -90
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeInvalidImapbParams = -85
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeMissingMandatoryItem = -86
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeOutOfRange = -82
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeRecordTooLarge = -81
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeReservedTagInUnknown = -87
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeStringTooLong = -83
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeUnsupportedImapbLength = -84
pub tst_pipeline::binding::BindingErrorKind::KlvEncodeVTargetPackEmpty = -88
pub tst_pipeline::binding::BindingErrorKind::KlvTooLarge = -5
pub tst_pipeline::binding::BindingErrorKind::MispTime = -45
pub tst_pipeline::binding::BindingErrorKind::MispTimeMalformed = -46
pub tst_pipeline::binding::BindingErrorKind::NotAvailable = -13
pub tst_pipeline::binding::BindingErrorKind::NotFound = -14
pub tst_pipeline::binding::BindingErrorKind::PanicCaught = -11
pub tst_pipeline::binding::BindingErrorKind::RistContextCreateFailed = -61
pub tst_pipeline::binding::BindingErrorKind::RistEncryptionDisabled = -41
pub tst_pipeline::binding::BindingErrorKind::RistFfi = -38
pub tst_pipeline::binding::BindingErrorKind::RistInvalidConfig = -39
pub tst_pipeline::binding::BindingErrorKind::RistPeerCreateFailed = -62
pub tst_pipeline::binding::BindingErrorKind::RistUrl = -60
pub tst_pipeline::binding::BindingErrorKind::RtpHostNotLiteral = -66
pub tst_pipeline::binding::BindingErrorKind::RtpIfaceUnsupported = -68
pub tst_pipeline::binding::BindingErrorKind::RtpIo = -67
pub tst_pipeline::binding::BindingErrorKind::RtpMissingPayloadTypeParam = -64
pub tst_pipeline::binding::BindingErrorKind::RtpPayloadTypeParam = -63
pub tst_pipeline::binding::BindingErrorKind::RtpUrl = -65
pub tst_pipeline::binding::BindingErrorKind::RtspAuthFailed = -17
pub tst_pipeline::binding::BindingErrorKind::RtspAuthRequired = -18
pub tst_pipeline::binding::BindingErrorKind::RtspIo = -22
pub tst_pipeline::binding::BindingErrorKind::RtspMount = -25
pub tst_pipeline::binding::BindingErrorKind::RtspNotFound = -19
pub tst_pipeline::binding::BindingErrorKind::RtspProtocol = -16
pub tst_pipeline::binding::BindingErrorKind::RtspServer = -24
pub tst_pipeline::binding::BindingErrorKind::RtspTimeout = -23
pub tst_pipeline::binding::BindingErrorKind::RtspTls = -21
pub tst_pipeline::binding::BindingErrorKind::RtspUnsupportedTransport = -20
pub tst_pipeline::binding::BindingErrorKind::SrtAcceptFailed = -50
pub tst_pipeline::binding::BindingErrorKind::SrtConnectFailed = -49
pub tst_pipeline::binding::BindingErrorKind::SrtIo = -52
pub tst_pipeline::binding::BindingErrorKind::SrtTimeout = -51
pub tst_pipeline::binding::BindingErrorKind::TcpConnectTimeout = -32
pub tst_pipeline::binding::BindingErrorKind::TcpInvalidConfig = -31
pub tst_pipeline::binding::BindingErrorKind::TcpIo = -30
pub tst_pipeline::binding::BindingErrorKind::TcpTls = -33
pub tst_pipeline::binding::BindingErrorKind::TcpTlsDisabled = -55
pub tst_pipeline::binding::BindingErrorKind::TcpUrl = -54
pub tst_pipeline::binding::BindingErrorKind::TooLarge = -6
pub tst_pipeline::binding::BindingErrorKind::UdpInvalidConfig = -27
pub tst_pipeline::binding::BindingErrorKind::UdpIo = -26
pub tst_pipeline::binding::BindingErrorKind::UdpUrl = -53
pub tst_pipeline::binding::BindingErrorKind::WrongType = -47
impl tst_pipeline::binding::kind::BindingErrorKind
pub const tst_pipeline::binding::kind::BindingErrorKind::ALL: &'static [tst_pipeline::binding::kind::BindingErrorKind]
pub fn tst_pipeline::binding::kind::BindingErrorKind::c_projection(&self) -> i32
pub fn tst_pipeline::binding::kind::BindingErrorKind::name(&self) -> &'static str
pub fn tst_pipeline::binding::kind::BindingErrorKind::variant_name(&self) -> &'static str
impl tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::c_code(&self) -> i32
pub fn tst_pipeline::binding::kind::BindingErrorKind::is_c_frozen(&self) -> bool
impl core::clone::Clone for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::clone(&self) -> tst_pipeline::binding::kind::BindingErrorKind
impl core::cmp::Eq for tst_pipeline::binding::kind::BindingErrorKind
impl core::cmp::PartialEq for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::eq(&self, &tst_pipeline::binding::kind::BindingErrorKind) -> bool
impl core::convert::From<tst_pipeline::shell_error::ShellErrorKind> for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::from(tst_pipeline::shell_error::ShellErrorKind) -> Self
impl core::fmt::Debug for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::hash::Hash for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::hash<__H: core::hash::Hasher>(&self, &mut __H)
impl core::marker::Copy for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::StructuralPartialEq for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Freeze for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Send for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Sync for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::Unpin for tst_pipeline::binding::kind::BindingErrorKind
impl core::marker::UnsafeUnpin for tst_pipeline::binding::kind::BindingErrorKind
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::kind::BindingErrorKind
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::kind::BindingErrorKind
pub enum tst_pipeline::binding::CloseFailure<E>
pub tst_pipeline::binding::CloseFailure::Inner(E)
pub tst_pipeline::binding::CloseFailure::Panicked
pub tst_pipeline::binding::CloseFailure::Panicked::detail: alloc::string::String
impl<E: core::fmt::Debug> core::fmt::Debug for tst_pipeline::binding::owned::CloseFailure<E>
pub fn tst_pipeline::binding::owned::CloseFailure<E>::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl<E: core::fmt::Display> core::convert::From<tst_pipeline::binding::owned::CloseFailure<E>> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::CloseFailure<E>) -> Self
impl<E> core::marker::Freeze for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Freeze
impl<E> core::marker::Send for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Send
impl<E> core::marker::Sync for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Sync
impl<E> core::marker::Unpin for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::Unpin
impl<E> core::marker::UnsafeUnpin for tst_pipeline::binding::owned::CloseFailure<E> where E: core::marker::UnsafeUnpin
impl<E> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::CloseFailure<E> where E: core::panic::unwind_safe::RefUnwindSafe
impl<E> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::CloseFailure<E> where E: core::panic::unwind_safe::UnwindSafe
#[non_exhaustive] pub enum tst_pipeline::binding::HandleState
pub tst_pipeline::binding::HandleState::Closed
pub tst_pipeline::binding::HandleState::Panicked
pub tst_pipeline::binding::HandleState::Panicked::detail: alloc::string::String
pub tst_pipeline::binding::HandleState::Poisoned
impl core::clone::Clone for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::clone(&self) -> tst_pipeline::binding::owned::HandleState
impl core::cmp::Eq for tst_pipeline::binding::owned::HandleState
impl core::cmp::PartialEq for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::eq(&self, &tst_pipeline::binding::owned::HandleState) -> bool
impl core::convert::From<tst_pipeline::binding::owned::HandleState> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::HandleState) -> Self
impl core::fmt::Debug for tst_pipeline::binding::owned::HandleState
pub fn tst_pipeline::binding::owned::HandleState::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::binding::owned::HandleState
impl core::marker::Freeze for tst_pipeline::binding::owned::HandleState
impl core::marker::Send for tst_pipeline::binding::owned::HandleState
impl core::marker::Sync for tst_pipeline::binding::owned::HandleState
impl core::marker::Unpin for tst_pipeline::binding::owned::HandleState
impl core::marker::UnsafeUnpin for tst_pipeline::binding::owned::HandleState
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::HandleState
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::HandleState
pub struct tst_pipeline::binding::BindingError
pub tst_pipeline::binding::BindingError::detail: alloc::string::String
pub tst_pipeline::binding::BindingError::kind: tst_pipeline::binding::kind::BindingErrorKind
impl tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::new(tst_pipeline::binding::kind::BindingErrorKind, impl core::convert::Into<alloc::string::String>) -> Self
impl core::clone::Clone for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::clone(&self) -> tst_pipeline::binding::kind::BindingError
impl core::cmp::Eq for tst_pipeline::binding::kind::BindingError
impl core::cmp::PartialEq for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::eq(&self, &tst_pipeline::binding::kind::BindingError) -> bool
impl core::convert::From<tst_core::codec::CodecParseError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::codec::CodecParseError) -> Self
impl core::convert::From<tst_core::error::DemuxError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::DemuxError) -> Self
impl core::convert::From<tst_core::error::KlvDecodeError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvDecodeError) -> Self
impl core::convert::From<tst_core::error::KlvEncodeError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvEncodeError) -> Self
impl core::convert::From<tst_core::error::KlvFieldError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::KlvFieldError) -> Self
impl core::convert::From<tst_core::error::MuxError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::error::MuxError) -> Self
impl core::convert::From<tst_core::transport::TransportError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_core::transport::TransportError) -> Self
impl core::convert::From<tst_pipeline::binding::owned::HandleState> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::HandleState) -> Self
impl core::convert::From<tst_pipeline::demux_receiver::DemuxReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::demux_receiver::DemuxReceiverError) -> Self
impl core::convert::From<tst_pipeline::mux_sender::MuxSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_sender::MuxSenderError) -> Self
impl core::convert::From<tst_pipeline::raw_receiver::RawReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_receiver::RawReceiverError) -> Self
impl core::convert::From<tst_pipeline::raw_sender::RawSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_sender::RawSenderError) -> Self
impl core::convert::From<tst_pipeline::receiver::ReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::receiver::ReceiverError) -> Self
impl core::convert::From<tst_pipeline::sender::SenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::SenderError) -> Self
impl core::convert::From<tst_pipeline::sender::TsFramingError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::TsFramingError) -> Self
impl core::error::Error for tst_pipeline::binding::kind::BindingError
impl core::fmt::Debug for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::fmt::Display for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::StructuralPartialEq for tst_pipeline::binding::kind::BindingError
impl<E: core::fmt::Display> core::convert::From<tst_pipeline::binding::owned::CloseFailure<E>> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::binding::owned::CloseFailure<E>) -> Self
impl<E> core::convert::From<tst_pipeline::mux_publisher::MuxPublisherError<E>> for tst_pipeline::binding::kind::BindingError where E: core::convert::Into<tst_pipeline::binding::kind::BindingError> + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_publisher::MuxPublisherError<E>) -> Self
impl core::marker::Freeze for tst_pipeline::binding::kind::BindingError
impl core::marker::Send for tst_pipeline::binding::kind::BindingError
impl core::marker::Sync for tst_pipeline::binding::kind::BindingError
impl core::marker::Unpin for tst_pipeline::binding::kind::BindingError
impl core::marker::UnsafeUnpin for tst_pipeline::binding::kind::BindingError
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::kind::BindingError
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::kind::BindingError
pub struct tst_pipeline::binding::FlagCancel(_)
impl tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::is_set(&self) -> bool
pub fn tst_pipeline::binding::owned::FlagCancel::new() -> Self
impl core::default::Default for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::default() -> tst_pipeline::binding::owned::FlagCancel
impl core::fmt::Debug for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl tst_core::transport::TransportCancel for tst_pipeline::binding::owned::FlagCancel
pub fn tst_pipeline::binding::owned::FlagCancel::cancel(&self)
pub fn tst_pipeline::binding::owned::FlagCancel::is_cancelled(&self) -> bool
impl !core::marker::Freeze for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Send for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Sync for tst_pipeline::binding::owned::FlagCancel
impl core::marker::Unpin for tst_pipeline::binding::owned::FlagCancel
impl core::marker::UnsafeUnpin for tst_pipeline::binding::owned::FlagCancel
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::FlagCancel
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::FlagCancel
pub struct tst_pipeline::binding::ManagedHandles
pub tst_pipeline::binding::ManagedHandles::attempts: alloc::sync::Arc<core::sync::atomic::AtomicU64>
pub tst_pipeline::binding::ManagedHandles::cancel: alloc::sync::Arc<dyn tst_core::transport::TransportCancel>
pub tst_pipeline::binding::ManagedHandles::end_reason: tst_pipeline::RecvEndReasonHandle
pub tst_pipeline::binding::ManagedHandles::reconnecting: alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub tst_pipeline::binding::ManagedHandles::reconnects: alloc::sync::Arc<core::sync::atomic::AtomicU64>
impl core::clone::Clone for tst_pipeline::binding::handles::ManagedHandles
pub fn tst_pipeline::binding::handles::ManagedHandles::clone(&self) -> tst_pipeline::binding::handles::ManagedHandles
impl core::fmt::Debug for tst_pipeline::binding::handles::ManagedHandles
pub fn tst_pipeline::binding::handles::ManagedHandles::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Send for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Sync for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::Unpin for tst_pipeline::binding::handles::ManagedHandles
impl core::marker::UnsafeUnpin for tst_pipeline::binding::handles::ManagedHandles
impl !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::handles::ManagedHandles
impl !core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::handles::ManagedHandles
pub struct tst_pipeline::binding::Owned<T, S>
impl<T, S> tst_pipeline::binding::owned::Owned<T, S>
pub fn tst_pipeline::binding::owned::Owned<T, S>::cancel(&self)
pub fn tst_pipeline::binding::owned::Owned<T, S>::cancel_arc(&self) -> alloc::sync::Arc<dyn tst_core::transport::TransportCancel>
pub fn tst_pipeline::binding::owned::Owned<T, S>::end_reason(&self) -> core::option::Option<tst_pipeline::RecvEndReason>
pub fn tst_pipeline::binding::owned::Owned<T, S>::is_cancelled(&self) -> bool
pub fn tst_pipeline::binding::owned::Owned<T, S>::is_closed(&self) -> bool
pub fn tst_pipeline::binding::owned::Owned<T, S>::new(T, alloc::sync::Arc<dyn tst_core::transport::TransportCancel>, S) -> Self
pub fn tst_pipeline::binding::owned::Owned<T, S>::snapshot(&self) -> &S
pub fn tst_pipeline::binding::owned::Owned<T, S>::take(&self) -> core::option::Option<T>
pub fn tst_pipeline::binding::owned::Owned<T, S>::try_with_ref<R>(&self, impl core::ops::function::FnOnce(&T) -> R) -> core::option::Option<core::result::Result<R, tst_pipeline::binding::owned::HandleState>>
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_end_reason(self, tst_pipeline::RecvEndReasonHandle) -> Self
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_mut<R>(&self, impl core::ops::function::FnOnce(&mut T) -> R) -> core::result::Result<R, tst_pipeline::binding::owned::HandleState>
pub fn tst_pipeline::binding::owned::Owned<T, S>::with_ref<R>(&self, impl core::ops::function::FnOnce(&T) -> R) -> core::result::Result<R, tst_pipeline::binding::owned::HandleState>
impl<T: tst_pipeline::binding::owned::Close, S> tst_pipeline::binding::owned::Owned<T, S>
pub fn tst_pipeline::binding::owned::Owned<T, S>::close(&self) -> core::result::Result<(), tst_pipeline::binding::owned::CloseFailure<<T as tst_pipeline::binding::owned::Close>::Error>>
impl<T, S> !core::marker::Freeze for tst_pipeline::binding::owned::Owned<T, S>
impl<T, S> core::marker::Send for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Send, T: core::marker::Send
impl<T, S> core::marker::Sync for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Sync, T: core::marker::Send
impl<T, S> core::marker::Unpin for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::Unpin, T: core::marker::Unpin
impl<T, S> core::marker::UnsafeUnpin for tst_pipeline::binding::owned::Owned<T, S> where S: core::marker::UnsafeUnpin, T: core::marker::UnsafeUnpin
impl<T, S> !core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::owned::Owned<T, S>
impl<T, S> !core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::owned::Owned<T, S>
pub struct tst_pipeline::binding::RecvHalf<R>(pub R)
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::RecvHalf<R>
pub type tst_pipeline::binding::shells::RecvHalf<R>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::RecvHalf<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R> core::marker::Freeze for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Freeze
impl<R> core::marker::Send for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Send
impl<R> core::marker::Sync for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Sync
impl<R> core::marker::Unpin for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::Unpin
impl<R> core::marker::UnsafeUnpin for tst_pipeline::binding::shells::RecvHalf<R> where R: core::marker::UnsafeUnpin
impl<R> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::shells::RecvHalf<R> where R: core::panic::unwind_safe::RefUnwindSafe
impl<R> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::shells::RecvHalf<R> where R: core::panic::unwind_safe::UnwindSafe
pub struct tst_pipeline::binding::SendHalf<T>(pub T)
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::SendHalf<T>
pub type tst_pipeline::binding::shells::SendHalf<T>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::SendHalf<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T> core::marker::Freeze for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Freeze
impl<T> core::marker::Send for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Send
impl<T> core::marker::Sync for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Sync
impl<T> core::marker::Unpin for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::Unpin
impl<T> core::marker::UnsafeUnpin for tst_pipeline::binding::shells::SendHalf<T> where T: core::marker::UnsafeUnpin
impl<T> core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::binding::shells::SendHalf<T> where T: core::panic::unwind_safe::RefUnwindSafe
impl<T> core::panic::unwind_safe::UnwindSafe for tst_pipeline::binding::shells::SendHalf<T> where T: core::panic::unwind_safe::UnwindSafe
pub trait tst_pipeline::binding::Close
pub type tst_pipeline::binding::Close::Error: core::fmt::Debug + core::fmt::Display
pub fn tst_pipeline::binding::Close::close(&mut self) -> core::result::Result<(), Self::Error>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::RecvHalf<R>
pub type tst_pipeline::binding::shells::RecvHalf<R>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::RecvHalf<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_receiver::RawReceiver<R>
pub type tst_pipeline::raw_receiver::RawReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<R: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::receiver::Receiver<R>
pub type tst_pipeline::receiver::Receiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::binding::shells::SendHalf<T>
pub type tst_pipeline::binding::shells::SendHalf<T>::Error = core::convert::Infallible
pub fn tst_pipeline::binding::shells::SendHalf<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::mux_sender::MuxSender<T>
pub type tst_pipeline::mux_sender::MuxSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_sender::RawSender<T>
pub type tst_pipeline::raw_sender::RawSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
impl<T: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::sender::Sender<T>
pub type tst_pipeline::sender::Sender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::sender::Sender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::demux_receiver::DemuxReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::demux_receiver::DemuxReceiverError) -> 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::file_transport
pub struct tst_pipeline::ext::file_transport::FileTransport
impl tst_pipeline::ext::file_transport::FileTransport
pub fn tst_pipeline::ext::file_transport::FileTransport::bytes_sent(&self) -> u64
pub fn tst_pipeline::ext::file_transport::FileTransport::create(impl core::convert::AsRef<std::path::Path>) -> core::io::error::Result<Self>
pub fn tst_pipeline::ext::file_transport::FileTransport::finish(self) -> core::io::error::Result<core::option::Option<std::fs::File>>
impl tst_core::transport::Transport for tst_pipeline::ext::file_transport::FileTransport
pub fn tst_pipeline::ext::file_transport::FileTransport::close(&mut self)
pub fn tst_pipeline::ext::file_transport::FileTransport::is_alive(&self) -> bool
pub fn tst_pipeline::ext::file_transport::FileTransport::max_payload(&self) -> usize
pub fn tst_pipeline::ext::file_transport::FileTransport::send_bytes(&mut self, &[u8]) -> core::result::Result<(), tst_core::transport::TransportError>
impl core::marker::Freeze for tst_pipeline::ext::file_transport::FileTransport
impl core::marker::Send for tst_pipeline::ext::file_transport::FileTransport
impl core::marker::Sync for tst_pipeline::ext::file_transport::FileTransport
impl core::marker::Unpin for tst_pipeline::ext::file_transport::FileTransport
impl core::marker::UnsafeUnpin for tst_pipeline::ext::file_transport::FileTransport
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::ext::file_transport::FileTransport
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::ext::file_transport::FileTransport
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::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>::add_byte_sink(&mut self, tst_pipeline::demux_receiver::ByteSink)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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>::end_reason_handle(&self) -> tst_pipeline::RecvEndReasonHandle
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>::reconnecting(&self) -> bool
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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>::new_with_factory_cancel(R, alloc::boxed::Box<(dyn core::ops::function::FnMut() -> core::result::Result<R, tst_core::transport::TransportError> + core::marker::Send)>, tst_pipeline::reconnect::ReconnectPolicy, alloc::sync::Arc<tst_pipeline::managed_receive::FactoryCancel>) -> Self
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
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 type tst_pipeline::managed_receive::FactoryCancel = tst_core::cancel::CancelSlot
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::LockPoisoned
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::convert::From<tst_pipeline::mux_publisher::MuxPublisherError<E>> for tst_pipeline::binding::kind::BindingError where E: core::convert::Into<tst_pipeline::binding::kind::BindingError> + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_publisher::MuxPublisherError<E>) -> Self
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>::send_video_misp(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> 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>::finish(&self) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::into_inner(self) -> T
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_misp_to(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_misp_to_with_dts(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> 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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::mux_sender::MuxSender<T>
pub type tst_pipeline::mux_sender::MuxSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::input_consumed: core::option::Option<bool>
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::convert::From<tst_pipeline::mux_sender::MuxSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_sender::MuxSenderError) -> 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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_receiver::RawReceiver<R>
pub type tst_pipeline::raw_receiver::RawReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::raw_receiver::RawReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_receiver::RawReceiverError) -> 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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_sender::RawSender<T>
pub type tst_pipeline::raw_sender::RawSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::raw_sender::RawSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_sender::RawSenderError) -> 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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::receiver::Receiver<R>
pub type tst_pipeline::receiver::Receiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::receiver::ReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::receiver::ReceiverError) -> 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
#[non_exhaustive] pub enum tst_pipeline::reconnect::ReconnectMode
pub tst_pipeline::reconnect::ReconnectMode::Background
pub tst_pipeline::reconnect::ReconnectMode::Blocking
impl core::clone::Clone for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::clone(&self) -> tst_pipeline::reconnect::ReconnectMode
impl core::cmp::Eq for tst_pipeline::reconnect::ReconnectMode
impl core::cmp::PartialEq for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::eq(&self, &tst_pipeline::reconnect::ReconnectMode) -> bool
impl core::default::Default for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::default() -> tst_pipeline::reconnect::ReconnectMode
impl core::fmt::Debug for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::reconnect::ReconnectMode
impl core::marker::StructuralPartialEq for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Freeze for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Send for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Sync for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Unpin for tst_pipeline::reconnect::ReconnectMode
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ReconnectMode
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ReconnectMode
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ReconnectMode
#[non_exhaustive] pub enum tst_pipeline::reconnect::RecvEndReason
pub tst_pipeline::reconnect::RecvEndReason::Cancelled
pub tst_pipeline::reconnect::RecvEndReason::EndOfStream
pub tst_pipeline::reconnect::RecvEndReason::ReconnectExhausted
impl core::clone::Clone for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::clone(&self) -> tst_pipeline::RecvEndReason
impl core::cmp::Eq for tst_pipeline::RecvEndReason
impl core::cmp::PartialEq for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::eq(&self, &tst_pipeline::RecvEndReason) -> bool
impl core::fmt::Debug for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::RecvEndReason
impl core::marker::StructuralPartialEq for tst_pipeline::RecvEndReason
impl core::marker::Freeze for tst_pipeline::RecvEndReason
impl core::marker::Send for tst_pipeline::RecvEndReason
impl core::marker::Sync for tst_pipeline::RecvEndReason
impl core::marker::Unpin for tst_pipeline::RecvEndReason
impl core::marker::UnsafeUnpin for tst_pipeline::RecvEndReason
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::RecvEndReason
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::RecvEndReason
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::ManagedStatsHandle
impl tst_pipeline::reconnect::ManagedStatsHandle
pub fn tst_pipeline::reconnect::ManagedStatsHandle::stats(&self) -> core::option::Option<tst_pipeline::reconnect::ManagedTransportStats>
impl core::clone::Clone for tst_pipeline::reconnect::ManagedStatsHandle
pub fn tst_pipeline::reconnect::ManagedStatsHandle::clone(&self) -> tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Freeze for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Send for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Sync for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Unpin for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedStatsHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedStatsHandle
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedStatsHandle
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>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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
pub fn tst_pipeline::reconnect::ManagedTransport<T>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::stats_handle(&self) -> tst_pipeline::reconnect::ManagedStatsHandle
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: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::drop(&mut self)
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>
#[non_exhaustive] pub struct tst_pipeline::reconnect::ManagedTransportStats
pub tst_pipeline::reconnect::ManagedTransportStats::gap_bytes_dropped: u64
pub tst_pipeline::reconnect::ManagedTransportStats::gap_len: u64
pub tst_pipeline::reconnect::ManagedTransportStats::gap_messages_dropped: u64
pub tst_pipeline::reconnect::ManagedTransportStats::reconnect_attempts: u64
pub tst_pipeline::reconnect::ManagedTransportStats::reconnect_successes: u64
pub tst_pipeline::reconnect::ManagedTransportStats::reconnecting: bool
impl core::clone::Clone for tst_pipeline::reconnect::ManagedTransportStats
pub fn tst_pipeline::reconnect::ManagedTransportStats::clone(&self) -> tst_pipeline::reconnect::ManagedTransportStats
impl core::fmt::Debug for tst_pipeline::reconnect::ManagedTransportStats
pub fn tst_pipeline::reconnect::ManagedTransportStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Send for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Sync for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Unpin for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedTransportStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedTransportStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedTransportStats
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::mode: tst_pipeline::reconnect::ReconnectMode
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 struct tst_pipeline::reconnect::RecvEndReasonHandle(_)
impl tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::get(&self) -> core::option::Option<tst_pipeline::RecvEndReason>
impl core::clone::Clone for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::clone(&self) -> tst_pipeline::RecvEndReasonHandle
impl core::default::Default for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::default() -> tst_pipeline::RecvEndReasonHandle
impl core::fmt::Debug for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::RecvEndReasonHandle
impl core::marker::Send for tst_pipeline::RecvEndReasonHandle
impl core::marker::Sync for tst_pipeline::RecvEndReasonHandle
impl core::marker::Unpin for tst_pipeline::RecvEndReasonHandle
impl core::marker::UnsafeUnpin for tst_pipeline::RecvEndReasonHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::RecvEndReasonHandle
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::RecvEndReasonHandle
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::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::TsFramingError) -> 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::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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::sender::Sender<T>
pub type tst_pipeline::sender::Sender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::sender::Sender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::input_consumed: core::option::Option<bool>
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::SenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::SenderError) -> 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]) -> core::result::Result<(alloc::vec::Vec<alloc::vec::Vec<u8>>, &tst_pipeline::SenderStats), tst_pipeline::sender::TsFramingError>
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::convert::From<tst_pipeline::shell_error::ShellErrorKind> for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::from(tst_pipeline::shell_error::ShellErrorKind) -> Self
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::LockPoisoned
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::convert::From<tst_pipeline::mux_publisher::MuxPublisherError<E>> for tst_pipeline::binding::kind::BindingError where E: core::convert::Into<tst_pipeline::binding::kind::BindingError> + core::error::Error + core::marker::Send + core::marker::Sync + 'static
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_publisher::MuxPublisherError<E>) -> Self
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::ReconnectMode
pub tst_pipeline::ReconnectMode::Background
pub tst_pipeline::ReconnectMode::Blocking
impl core::clone::Clone for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::clone(&self) -> tst_pipeline::reconnect::ReconnectMode
impl core::cmp::Eq for tst_pipeline::reconnect::ReconnectMode
impl core::cmp::PartialEq for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::eq(&self, &tst_pipeline::reconnect::ReconnectMode) -> bool
impl core::default::Default for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::default() -> tst_pipeline::reconnect::ReconnectMode
impl core::fmt::Debug for tst_pipeline::reconnect::ReconnectMode
pub fn tst_pipeline::reconnect::ReconnectMode::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::reconnect::ReconnectMode
impl core::marker::StructuralPartialEq for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Freeze for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Send for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Sync for tst_pipeline::reconnect::ReconnectMode
impl core::marker::Unpin for tst_pipeline::reconnect::ReconnectMode
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ReconnectMode
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ReconnectMode
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ReconnectMode
#[non_exhaustive] pub enum tst_pipeline::RecvEndReason
pub tst_pipeline::RecvEndReason::Cancelled
pub tst_pipeline::RecvEndReason::EndOfStream
pub tst_pipeline::RecvEndReason::ReconnectExhausted
impl core::clone::Clone for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::clone(&self) -> tst_pipeline::RecvEndReason
impl core::cmp::Eq for tst_pipeline::RecvEndReason
impl core::cmp::PartialEq for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::eq(&self, &tst_pipeline::RecvEndReason) -> bool
impl core::fmt::Debug for tst_pipeline::RecvEndReason
pub fn tst_pipeline::RecvEndReason::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Copy for tst_pipeline::RecvEndReason
impl core::marker::StructuralPartialEq for tst_pipeline::RecvEndReason
impl core::marker::Freeze for tst_pipeline::RecvEndReason
impl core::marker::Send for tst_pipeline::RecvEndReason
impl core::marker::Sync for tst_pipeline::RecvEndReason
impl core::marker::Unpin for tst_pipeline::RecvEndReason
impl core::marker::UnsafeUnpin for tst_pipeline::RecvEndReason
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::RecvEndReason
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::RecvEndReason
#[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::convert::From<tst_pipeline::shell_error::ShellErrorKind> for tst_pipeline::binding::kind::BindingErrorKind
pub fn tst_pipeline::binding::kind::BindingErrorKind::from(tst_pipeline::shell_error::ShellErrorKind) -> Self
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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::demux_receiver::DemuxReceiver<R>
pub type tst_pipeline::demux_receiver::DemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::demux_receiver::DemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::demux_receiver::DemuxReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::demux_receiver::DemuxReceiverError) -> 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>::add_byte_sink(&mut self, tst_pipeline::demux_receiver::ByteSink)
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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>::end_reason_handle(&self) -> tst_pipeline::RecvEndReasonHandle
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>::reconnecting(&self) -> bool
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_count(&self) -> u64
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>
pub type tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::managed_demux_receiver::ManagedDemuxReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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>::new_with_factory_cancel(R, alloc::boxed::Box<(dyn core::ops::function::FnMut() -> core::result::Result<R, tst_core::transport::TransportError> + core::marker::Send)>, tst_pipeline::reconnect::ReconnectPolicy, alloc::sync::Arc<tst_pipeline::managed_receive::FactoryCancel>) -> Self
pub fn tst_pipeline::managed_receive::ManagedRecvTransport<R>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
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::ManagedStatsHandle
impl tst_pipeline::reconnect::ManagedStatsHandle
pub fn tst_pipeline::reconnect::ManagedStatsHandle::stats(&self) -> core::option::Option<tst_pipeline::reconnect::ManagedTransportStats>
impl core::clone::Clone for tst_pipeline::reconnect::ManagedStatsHandle
pub fn tst_pipeline::reconnect::ManagedStatsHandle::clone(&self) -> tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Freeze for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Send for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Sync for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::Unpin for tst_pipeline::reconnect::ManagedStatsHandle
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedStatsHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedStatsHandle
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedStatsHandle
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>::attempts_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
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
pub fn tst_pipeline::reconnect::ManagedTransport<T>::reconnecting_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicBool>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::reconnects_handle(&self) -> alloc::sync::Arc<core::sync::atomic::AtomicU64>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::stats_handle(&self) -> tst_pipeline::reconnect::ManagedStatsHandle
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: tst_core::transport::Transport> core::ops::drop::Drop for tst_pipeline::reconnect::ManagedTransport<T>
pub fn tst_pipeline::reconnect::ManagedTransport<T>::drop(&mut self)
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>
#[non_exhaustive] pub struct tst_pipeline::ManagedTransportStats
pub tst_pipeline::ManagedTransportStats::gap_bytes_dropped: u64
pub tst_pipeline::ManagedTransportStats::gap_len: u64
pub tst_pipeline::ManagedTransportStats::gap_messages_dropped: u64
pub tst_pipeline::ManagedTransportStats::reconnect_attempts: u64
pub tst_pipeline::ManagedTransportStats::reconnect_successes: u64
pub tst_pipeline::ManagedTransportStats::reconnecting: bool
impl core::clone::Clone for tst_pipeline::reconnect::ManagedTransportStats
pub fn tst_pipeline::reconnect::ManagedTransportStats::clone(&self) -> tst_pipeline::reconnect::ManagedTransportStats
impl core::fmt::Debug for tst_pipeline::reconnect::ManagedTransportStats
pub fn tst_pipeline::reconnect::ManagedTransportStats::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Send for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Sync for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::Unpin for tst_pipeline::reconnect::ManagedTransportStats
impl core::marker::UnsafeUnpin for tst_pipeline::reconnect::ManagedTransportStats
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::reconnect::ManagedTransportStats
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::reconnect::ManagedTransportStats
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>::send_video_misp(&self, &[u8], tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> 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>::finish(&self) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::into_inner(self) -> T
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_misp_to(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> core::result::Result<(), tst_pipeline::mux_sender::MuxSenderError>
pub fn tst_pipeline::mux_sender::MuxSender<T>::send_video_misp_to_with_dts(&self, tst_core::mpegts::mux::types::VideoStreamHandle, &[u8], tst_core::mpegts::common::Pts90khz, tst_core::mpegts::common::Pts90khz, bool, &tst_core::codec::misp_time::MispTimestamp) -> 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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::mux_sender::MuxSender<T>
pub type tst_pipeline::mux_sender::MuxSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::mux_sender::MuxSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::input_consumed: core::option::Option<bool>
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::convert::From<tst_pipeline::mux_sender::MuxSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::mux_sender::MuxSenderError) -> 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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_receiver::RawReceiver<R>
pub type tst_pipeline::raw_receiver::RawReceiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_receiver::RawReceiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::raw_receiver::RawReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_receiver::RawReceiverError) -> 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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::raw_sender::RawSender<T>
pub type tst_pipeline::raw_sender::RawSender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::raw_sender::RawSender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::raw_sender::RawSenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::raw_sender::RawSenderError) -> 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: tst_core::transport::RecvTransport> tst_pipeline::binding::owned::Close for tst_pipeline::receiver::Receiver<R>
pub type tst_pipeline::receiver::Receiver<R>::Error = core::convert::Infallible
pub fn tst_pipeline::receiver::Receiver<R>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::convert::From<tst_pipeline::receiver::ReceiverError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::receiver::ReceiverError) -> 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::mode: tst_pipeline::reconnect::ReconnectMode
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::RecvEndReasonHandle(_)
impl tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::get(&self) -> core::option::Option<tst_pipeline::RecvEndReason>
impl core::clone::Clone for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::clone(&self) -> tst_pipeline::RecvEndReasonHandle
impl core::default::Default for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::default() -> tst_pipeline::RecvEndReasonHandle
impl core::fmt::Debug for tst_pipeline::RecvEndReasonHandle
pub fn tst_pipeline::RecvEndReasonHandle::fmt(&self, &mut core::fmt::Formatter<'_>) -> core::fmt::Result
impl core::marker::Freeze for tst_pipeline::RecvEndReasonHandle
impl core::marker::Send for tst_pipeline::RecvEndReasonHandle
impl core::marker::Sync for tst_pipeline::RecvEndReasonHandle
impl core::marker::Unpin for tst_pipeline::RecvEndReasonHandle
impl core::marker::UnsafeUnpin for tst_pipeline::RecvEndReasonHandle
impl core::panic::unwind_safe::RefUnwindSafe for tst_pipeline::RecvEndReasonHandle
impl core::panic::unwind_safe::UnwindSafe for tst_pipeline::RecvEndReasonHandle
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: tst_core::transport::Transport> tst_pipeline::binding::owned::Close for tst_pipeline::sender::Sender<T>
pub type tst_pipeline::sender::Sender<T>::Error = core::convert::Infallible
pub fn tst_pipeline::sender::Sender<T>::close(&mut self) -> core::result::Result<(), core::convert::Infallible>
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::input_consumed: core::option::Option<bool>
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::SenderError> for tst_pipeline::binding::kind::BindingError
pub fn tst_pipeline::binding::kind::BindingError::from(tst_pipeline::sender::SenderError) -> 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)>
pub type tst_pipeline::FactoryCancel = tst_core::cancel::CancelSlot
