pub struct FramedReader<R> { /* private fields */ }Expand description
Reads packets from an AsyncRead.
Implementations§
Source§impl<R: AsyncRead + Unpin> FramedReader<R>
impl<R: AsyncRead + Unpin> FramedReader<R>
Sourcepub fn decoder(&mut self) -> &mut FrameDecoder
pub fn decoder(&mut self) -> &mut FrameDecoder
The frame decoder (compression, encryption, filter, limits, stats).
Sourcepub async fn read_packet(&mut self) -> Result<Option<RawPacket>, FrameError>
pub async fn read_packet(&mut self) -> Result<Option<RawPacket>, FrameError>
Reads the next packet that passes the filter. Ok(None) on a clean end of
stream (no partial frame buffered).
Cancel safe: if the future is dropped, no data is lost.
Trait Implementations§
Auto Trait Implementations§
impl<R> !UnwindSafe for FramedReader<R>
impl<R> Forget for FramedReader<R>
impl<R> Freeze for FramedReader<R>where
R: Freeze,
impl<R> RefUnwindSafe for FramedReader<R>where
R: RefUnwindSafe,
impl<R> Send for FramedReader<R>where
R: Send,
impl<R> Sync for FramedReader<R>where
R: Sync,
impl<R> Unpin for FramedReader<R>where
R: Unpin,
impl<R> UnsafeUnpin for FramedReader<R>where
R: UnsafeUnpin,
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