Struct fluvio_future::io::Repeat

source · [−]

pub struct Repeat { /* private fields */ }

Expand description

A reader which yields one byte over and over and over and over and over and…

This reader is created by the repeat function. See its documentation for more.

Trait Implementations

source

impl AsyncRead for Repeat

source

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

Attempt to read from the AsyncRead into buf. Read more

fn poll_read_vectored(
 self: Pin<&mut Self>,
 cx: &mut Context<'_>,
 bufs: &mut [IoSliceMut<'_>]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations. Read more

source

impl Debug for Repeat

source

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl RefUnwindSafe for Repeat

impl Send for Repeat

impl Sync for Repeat

impl Unpin for Repeat

impl UnwindSafe for Repeat

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

source

fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self>ⓘNotable traits for ReadFuture<'_, R>`impl<R> Future for ReadFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
Self: Unpin,

Reads some bytes from the byte stream. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self>ⓘNotable traits for ReadVectoredFuture<'_, R>`impl<R> Future for ReadVectoredFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
 Self: Unpin,

Like read(), except it reads into a slice of buffers. Read more

source

fn read_to_end(
 &'a mut self,
 buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self>ⓘNotable traits for ReadToEndFuture<'_, R>`impl<R> Future for ReadToEndFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
 Self: Unpin,

Reads the entire contents and appends them to a Vec. Read more

source

fn read_to_string(
 &'a mut self,
 buf: &'a mut String
) -> ReadToStringFuture<'a, Self>ⓘNotable traits for ReadToStringFuture<'_, R>`impl<R> Future for ReadToStringFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
 Self: Unpin,

Reads the entire contents and appends them to a String. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self>ⓘNotable traits for ReadExactFuture<'_, R>`impl<R> Future for ReadExactFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<(), Error>;` where
Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an adapter which will read at most limit bytes from it. Read more

source

fn bytes(self) -> Bytes<Self>

Converts this AsyncRead into a Stream of bytes. Read more

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adapter which will chain this stream with another. Read more

source

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>>ⓘNotable traits for Pin`impl Future for Pin where P: DerefMut, ::Target: Future, type Output = <::Target as Future>::Output;` where
Self: 'a + Send,

Boxes the reader and changes its type to dyn AsyncRead + Send + 'a. Read more

source

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adaptor which will chain this stream with another. Read more

source

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

Tries to read some bytes directly into the given buf in asynchronous manner, returning a future type. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
 Self: Unpin,

Creates a future which will read from the AsyncRead into bufs using vectored IO operations. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where
Self: Unpin,

Creates a future which will read exactly enough bytes to fill buf, returning an error if end of file (EOF) is hit sooner. Read more

source

fn read_to_end(&'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEnd<'a, Self> where
Self: Unpin,

Creates a future which will read all the bytes from this AsyncRead. Read more

source

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where
Self: Unpin,

Creates a future which will read all the bytes from this AsyncRead. Read more

source

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
Self: AsyncWrite,

Helper method for splitting this read/write object into two halves. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an AsyncRead adapter which will read at most limit bytes from the underlying reader. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source

impl<T> ReadExt for T where
T: AsyncRead + ?Sized,

source

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

Reads some bytes from the byte stream. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
 Self: Unpin,

Like read, except that it reads into a slice of buffers. Read more

source

fn read_to_end(
 &'a mut self,
 buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
 Self: Unpin,

Reads all bytes from the byte stream. Read more

source

fn read_to_string(
 &'a mut self,
 buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
 Self: Unpin,

Reads all bytes from the byte stream and appends them into a string. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an adaptor which will read at most limit bytes from it. Read more

source

fn by_ref(&mut self) -> &mut Self

Creates a “by reference” adaptor for this instance of Read. Read more

source

fn bytes(self) -> Bytes<Self>

Transforms this Read instance to a Stream over its bytes. Read more

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adaptor which will chain this stream with another. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;` where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;`

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

Struct fluvio_future::io::Repeat

Trait Implementations

impl AsyncRead for Repeat

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

fn poll_read_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &mut [IoSliceMut<'_>]) -> Poll<Result<usize, Error>>

impl Debug for Repeat

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Auto Trait Implementations

impl RefUnwindSafe for Repeat

impl Send for Repeat

impl Sync for Repeat

impl Unpin for Repeat

impl UnwindSafe for Repeat

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<R> AsyncReadExt for R where R: AsyncRead + ?Sized,

fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self>ⓘNotable traits for ReadFuture<'_, R>impl<R> Future for ReadFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>; where Self: Unpin,

fn read_vectored( &'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectoredFuture<'a, Self>ⓘNotable traits for ReadVectoredFuture<'_, R>impl<R> Future for ReadVectoredFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>; where Self: Unpin,

fn read_to_end( &'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEndFuture<'a, Self>ⓘNotable traits for ReadToEndFuture<'_, R>impl<R> Future for ReadToEndFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>; where Self: Unpin,

fn read_to_string( &'a mut self, buf: &'a mut String) -> ReadToStringFuture<'a, Self>ⓘNotable traits for ReadToStringFuture<'_, R>impl<R> Future for ReadToStringFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>; where Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self>ⓘNotable traits for ReadExactFuture<'_, R>impl<R> Future for ReadExactFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<(), Error>; where Self: Unpin,

fn take(self, limit: u64) -> Take<Self>

fn bytes(self) -> Bytes<Self>

fn chain<R>(self, next: R) -> Chain<Self, R> where R: AsyncRead,

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>>ⓘNotable traits for Pin<P>impl<P> Future for Pin<P> where P: DerefMut, <P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output; where Self: 'a + Send,

impl<R> AsyncReadExt for R where R: AsyncRead + ?Sized,

fn chain<R>(self, next: R) -> Chain<Self, R> where R: AsyncRead,

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

fn read_vectored( &'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectored<'a, Self> where Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where Self: Unpin,

fn read_to_end(&'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEnd<'a, Self> where Self: Unpin,

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where Self: Unpin,

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where Self: AsyncWrite,

fn take(self, limit: u64) -> Take<Self>

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;

fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;

impl<T, U> Into<U> for T where U: From<T>,

fn into(self) -> U

impl<T> ReadExt for T where T: AsyncRead + ?Sized,

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

fn read_vectored( &'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectoredFuture<'a, Self> where Self: Unpin,

fn read_to_end( &'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEndFuture<'a, Self> where Self: Unpin,

fn read_to_string( &'a mut self, buf: &'a mut String) -> ReadToStringFuture<'a, Self> where Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where Self: Unpin,

fn take(self, limit: u64) -> Take<Self>

fn by_ref(&mut self) -> &mut Self

fn bytes(self) -> Bytes<Self>

fn chain<R>(self, next: R) -> Chain<Self, R> where R: AsyncRead,

impl<T, U> TryFrom<U> for T where U: Into<T>,

type Error = Infallible

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

impl<T, U> TryInto<U> for T where U: TryFrom<T>,

type Error = <U as TryFrom<T>>::Error

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output; where S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;

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

fn poll_read_vectored(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
bufs: &mut [IoSliceMut<'_>]
) -> Poll<Result<usize, Error>>

impl<T> Any for T where
T: 'static + ?Sized,

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self>ⓘNotable traits for ReadFuture<'_, R>`impl<R> Future for ReadFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
Self: Unpin,

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self>ⓘNotable traits for ReadVectoredFuture<'_, R>`impl<R> Future for ReadVectoredFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
Self: Unpin,

fn read_to_end(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self>ⓘNotable traits for ReadToEndFuture<'_, R>`impl<R> Future for ReadToEndFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
Self: Unpin,

fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self>ⓘNotable traits for ReadToStringFuture<'_, R>`impl<R> Future for ReadToStringFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<usize, Error>;` where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self>ⓘNotable traits for ReadExactFuture<'_, R>`impl<R> Future for ReadExactFuture<'_, R> where R: AsyncRead + Unpin + ?Sized, type Output = Result<(), Error>;` where
Self: Unpin,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>>ⓘNotable traits for Pin<P>`impl<P> Future for Pin<P> where P: DerefMut, <P as Deref>::Target: Future, type Output = <<P as Deref>::Target as Future>::Output;` where
Self: 'a + Send,

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

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

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where
Self: Unpin,

fn read_to_end(&'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEnd<'a, Self> where
Self: Unpin,

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where
Self: Unpin,

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
Self: AsyncWrite,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

fn instrument(self, span: Span) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

fn in_current_span(self) -> Instrumented<Self>ⓘNotable traits for Instrumented<T>`impl<T> Future for Instrumented<T> where T: Future, type Output = <T as Future>::Output;`

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ReadExt for T where
T: AsyncRead + ?Sized,

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

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,

fn read_to_end(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
Self: Unpin,

fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;` where
S: Into<Dispatch>,

fn with_current_subscriber(self) -> WithDispatch<Self>ⓘNotable traits for WithDispatch<T>`impl<T> Future for WithDispatch<T> where T: Future, type Output = <T as Future>::Output;`