pub fn poll_read_decrypted<R>(
        &mut self,
        ctx: &mut Context<'_>,
        r: &mut R,
        dst: &mut ReadBuf<'_>,
    ) -> Poll<io::Result<()>>
    where
        R: AsyncRead + Unpin,
    {
        let filled = dst.filled().len();
        ready!(Pin::new(r).poll_read(ctx, dst))?;

        // Decrypt inplace
        let m = &mut dst.filled_mut()[filled..];
        if !m.is_empty() {
            assert_eq!(self.cipher.decrypt_packet(m), true);
        }

        Poll::Ready(Ok(()))
    }
/// Attempt to read decrypted data from reader
Attempt to read decrypted data from reader
Attempt to read decrypted data from reader
pub fn poll_read_decrypted<R>(
        &mut self,
        ctx: &mut Context<'_>,
        r: &mut R,
        dst: &mut ReadBuf<'_>,
    ) -> Poll<io::Result<()>>
    where
        R: AsyncRead + Unpin,
    {
        let filled = dst.filled().len();
        ready!(Pin::new(r).poll_read(ctx, dst))?;
        // Decrypt inplace
        let m = &mut dst.filled_mut()[filled..];
        if !m.is_empty() {
            assert_eq!(self.cipher.decrypt_packet(m), true);
        }
        Poll::Ready(Ok(()))
    }
pub fn poll_read_decrypted < R > ( & mut self , ctx : & mut Context < ' _ > , r : & mut R , dst : & mut ReadBuf < ' _ > , ) -> Poll < io :: Result < ( ) > > where R : AsyncRead + Unpin , { let filled = dst . filled ( ) . len ( ) ; ready ! ( Pin new ( r ) poll_read ( ctx dst ) ) ? ; // Decrypt inplace let m = & mut dst . filled_mut ( ) [ filled .. ] ; if ! m . is_empty ( ) { assert_eq ! ( self cipher decrypt_packet ( m ) true ) ; } Poll :: Ready ( Ok ( ( ) ) ) }
Attempt to read decrypted data from reader
Attempt to read decrypted data from reader
&mut self
ctx
&mut Context<'_>
r
&mut R
dst
&mut ReadBuf<'_>