pub struct CompressedReceiver { /* private fields */ }Expand description
Receiving half: applies tagged template updates, decompresses tagged data items into full slots.
Implementations§
Source§impl CompressedReceiver
impl CompressedReceiver
Sourcepub fn new(inner: ReliableUdpReceiver) -> Self
pub fn new(inner: ReliableUdpReceiver) -> Self
Wrap an existing receiver.
Sourcepub fn bind(local: SocketAddr) -> Result<Self>
pub fn bind(local: SocketAddr) -> Result<Self>
Bind a fresh receiver on local, wrapped.
Sourcepub fn poll(&mut self) -> Result<Vec<Vec<u8>>>
pub fn poll(&mut self) -> Result<Vec<Vec<u8>>>
Poll the transport, returning decompressed slots in stream order. A template item updates the decoder and emits no slot; a data item is decompressed with the current template.
Sourcepub fn nudge_feedback(&mut self) -> Result<()>
pub fn nudge_feedback(&mut self) -> Result<()>
Drive tail-ARQ feedback when idle (delegates to the inner receiver).
Sourcepub fn with_debug_loss(self, pct: u32, seed: u64) -> Self
pub fn with_debug_loss(self, pct: u32, seed: u64) -> Self
Inject diagnostic loss on the inner receiver (test surface).
Auto Trait Implementations§
impl !RefUnwindSafe for CompressedReceiver
impl !Send for CompressedReceiver
impl !Sync for CompressedReceiver
impl !UnwindSafe for CompressedReceiver
impl Freeze for CompressedReceiver
impl Unpin for CompressedReceiver
impl UnsafeUnpin for CompressedReceiver
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more