Struct embedded_io::adapters::FromTokio

pub struct FromTokio<T: ?Sized> { /* private fields */ }

Available on crate feature tokio only.

Adapter from tokio::io traits.

Implementations

impl<T> FromTokio<T>

pub fn new(inner: T) -> Self

Create a new adapter.

pub fn into_inner(self) -> T

Consume the adapter, returning the inner object.

impl<T: ?Sized> FromTokio<T>

pub fn inner(&self) -> &T

Borrow the inner object.

pub fn inner_mut(&mut self) -> &mut T

Mutably borrow the inner object.

Trait Implementations

impl<T: ?Sized> Io for FromTokio<T>

type Error = Error

Error type of all the IO operations on this type.

impl<T: AsyncRead + Unpin + ?Sized> Read for FromTokio<T>

type ReadFuture<'a>
where
    Self: 'a = impl Future<Output = Result<usize, <FromTokio<T> as Io>::Error>>

Available on crate feature async only.

Future returned by read.

fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Self::ReadFuture<'a>

Available on crate feature async only.

Pull some bytes from this source into the specified buffer, returning how many bytes were read.

fn read_exact<'a>(
    &'a mut self,
    buf: &'a mut [u8]
) -> impl Future<Output = Result<(), ReadExactError<Self::Error>>>

Available on crate feature async only.

Read the exact number of bytes required to fill buf.

impl<T: AsyncWrite + Unpin + ?Sized> Write for FromTokio<T>

type WriteFuture<'a>
where
    Self: 'a = impl Future<Output = Result<usize, <FromTokio<T> as Io>::Error>>

Available on crate feature async only.

Future returned by write.

type FlushFuture<'a>
where
    Self: 'a = impl Future<Output = Result<(), <FromTokio<T> as Io>::Error>>

Available on crate feature async only.

Future returned by flush.

fn write<'a>(&'a mut self, buf: &'a [u8]) -> Self::WriteFuture<'a>

Available on crate feature async only.

Write a buffer into this writer, returning how many bytes were written.

fn flush<'a>(&'a mut self) -> Self::FlushFuture<'a>

Available on crate feature async only.

Flush this output stream, ensuring that all intermediately buffered contents reach their destination.

fn write_all<'a>(
    &'a mut self,
    buf: &'a [u8]
) -> impl Future<Output = Result<(), Self::Error>>

Available on crate feature async only.

Write an entire buffer into this writer.