Struct iso_tp::transport::reader::Reader

pub struct Reader<T, E> { /* private fields */ }

Implementations

impl<T, E> Reader<T, E>

pub fn new(transport: T) -> Self

Create a new reader from a socket.

pub async fn abort(self) -> Result<(), T::Error>where T: Sink<Frame> + Unpin,

Abort the current read.

Trait Implementations

impl<T, E> AsyncRead for Reader<T, E>where T: Sink<Frame> + Stream<Item = Result<Frame, E>>,

type Error = Error<<T as Sink<Frame>>::Error, E>

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut [u8] ) -> Poll<Result<usize, Self::Error>>

Attempt to read from the AsyncRead into buf. On success, returns Poll::Ready(Ok(num_bytes_read)). If no data is available for reading, this method returns Poll::Pending and arranges for the current task to be woken.

impl<'__pin, T, E> Unpin for Reader<T, E>where __Origin<'__pin, T, E>: Unpin,