Struct embedded_io::adapters::FromFutures

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

Available on crate feature futures only.

Adapter from futures::io traits.

Implementations

impl<T> FromFutures<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> FromFutures<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 FromFutures<T>

type Error = Error

Error type of all the IO operations on this type.

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

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

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>>> + 'a

Available on crate feature async only.

Read the exact number of bytes required to fill buf.

impl<T: AsyncSeek + Unpin + ?Sized> Seek for FromFutures<T>

type SeekFuture<'a>
where
    Self: 'a = impl Future<Output = Result<u64, <FromFutures<T> as Io>::Error>> + 'a

Available on crate feature async only.

Future returned by seek.

fn seek<'a>(&'a mut self, pos: SeekFrom) -> Self::SeekFuture<'a>

Available on crate feature async only.

Seek to an offset, in bytes, in a stream.

fn rewind<'a>(
    &'a mut self
) -> impl Future<Output = Result<(), Self::Error>> + 'a

Available on crate feature async only.

Rewind to the beginning of a stream.

fn stream_position<'a>(&'a mut self) -> Self::SeekFuture<'a>

Available on crate feature async only.

Returns the current seek position from the start of the stream.

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

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

Available on crate feature async only.

Future returned by write.

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

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>> + 'a

Available on crate feature async only.

Write an entire buffer into this writer.