Struct futures::compat::Compat [−][src]
pub struct Compat<T> { /* fields omitted */ }
compat
only.Expand description
Implementations
Creates a new Compat
.
For types which implement appropriate futures 0.3
traits, the result will be a type which implements
the corresponding futures 0.1 type.
Get a reference to 0.3 Future, Stream, AsyncRead, or AsyncWrite object contained within.
Get a mutable reference to 0.3 Future, Stream, AsyncRead, or AsyncWrite object contained within.
Returns the inner item.
Trait Implementations
Prepares an uninitialized buffer to be safe to pass to read
. Returns
true
if the supplied buffer was zeroed out. Read more
Attempt to read from the AsyncRead
into buf
. Read more
Pull some bytes from this source into the specified BufMut
, returning
how many bytes were read. Read more
Use tokio_codec::Decoder::framed instead
Provides a Stream
and Sink
interface for reading and writing to this
I/O object, using Decode
and Encode
to read and write the raw data. Read more
The type of value that this future will resolved with if it is successful. Read more
The type of error that this future will resolve with if it fails in a normal fashion. Read more
Query this future to see if its value has become available, registering interest if it is not. Read more
Block the current thread until this future is resolved. Read more
Map this future’s result to a different type, returning a new future of the resulting type. Read more
Map this future’s error to a different error, returning a new future. Read more
Map this future’s error to any error implementing From
for
this future’s Error
, returning a new future. Read more
Chain on a computation for when a future finished, passing the result of
the future to the provided closure f
. Read more
Execute another future after this one has resolved successfully. Read more
Execute another future if this one resolves with an error. Read more
fn select<B>(self, other: B) -> Select<Self, <B as IntoFuture>::Future> where
B: IntoFuture<Item = Self::Item, Error = Self::Error>,
fn select<B>(self, other: B) -> Select<Self, <B as IntoFuture>::Future> where
B: IntoFuture<Item = Self::Item, Error = Self::Error>,
Waits for either one of two futures to complete. Read more
Waits for either one of two differently-typed futures to complete. Read more
fn join<B>(self, other: B) -> Join<Self, <B as IntoFuture>::Future> where
B: IntoFuture<Error = Self::Error>,
fn join<B>(self, other: B) -> Join<Self, <B as IntoFuture>::Future> where
B: IntoFuture<Error = Self::Error>,
Joins the result of two futures, waiting for them both to complete. Read more
fn join3<B, C>(
self,
b: B,
c: C
) -> Join3<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
fn join3<B, C>(
self,
b: B,
c: C
) -> Join3<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
Same as join
, but with more futures.
fn join4<B, C, D>(
self,
b: B,
c: C,
d: D
) -> Join4<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
fn join4<B, C, D>(
self,
b: B,
c: C,
d: D
) -> Join4<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
Same as join
, but with more futures.
fn join5<B, C, D, E>(
self,
b: B,
c: C,
d: D,
e: E
) -> Join5<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future, <E as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
E: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
fn join5<B, C, D, E>(
self,
b: B,
c: C,
d: D,
e: E
) -> Join5<Self, <B as IntoFuture>::Future, <C as IntoFuture>::Future, <D as IntoFuture>::Future, <E as IntoFuture>::Future> where
C: IntoFuture<Error = Self::Error>,
E: IntoFuture<Error = Self::Error>,
B: IntoFuture<Error = Self::Error>,
D: IntoFuture<Error = Self::Error>,
Same as join
, but with more futures.
Convert this future into a single element stream. Read more
fn flatten(self) -> Flatten<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error: From<Self::Error>,
fn flatten(self) -> Flatten<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error: From<Self::Error>,
Flatten the execution of this future when the successful result of this future is itself another future. Read more
fn flatten_stream(self) -> FlattenStream<Self> where
Self::Item: Stream,
<Self::Item as Stream>::Error == Self::Error,
fn flatten_stream(self) -> FlattenStream<Self> where
Self::Item: Stream,
<Self::Item as Stream>::Error == Self::Error,
Flatten the execution of this future when the successful result of this future is a stream. Read more
Fuse a future such that poll
will never again be called once it has
completed. Read more
Do something with the item of a future, passing it on. Read more
Catches unwinding panics while polling the future. Read more
Create a cloneable handle to this future where all handles will resolve to the same result. Read more
Pull some bytes from this source into the specified buffer, returning how many bytes were read. Read more
Like read
, except that it reads into a slice of buffers. Read more
can_vector
)Determines if this Read
er has an efficient read_vectored
implementation. Read more
read_initializer
)Determines if this Read
er can work with buffers of uninitialized
memory. Read more
Read all bytes until EOF in this source, placing them into buf
. Read more
Read all bytes until EOF in this source, appending them to buf
. Read more
Read the exact number of bytes required to fill buf
. Read more
Creates a “by reference” adapter for this instance of Read
. Read more
Creates an adapter which will chain this stream with another. Read more
Attempt to pull out the next value of this stream, returning None
if
the stream is finished. Read more
Creates an iterator which blocks the current thread until each item of this stream is resolved. Read more
Converts this stream into a Future
. Read more
Converts a stream of type T
to a stream of type U
. Read more
Converts a stream of error type T
to a stream of error type U
. Read more
Filters the values produced by this stream according to the provided predicate. Read more
Filters the values produced by this stream while simultaneously mapping them to a different type. Read more
Chain on a computation for when a value is ready, passing the resulting
item to the provided closure f
. Read more
Chain on a computation for when a value is ready, passing the successful
results to the provided closure f
. Read more
Chain on a computation for when an error happens, passing the
erroneous result to the provided closure f
. Read more
Collect all of the values of this stream into a vector, returning a future representing the result of that computation. Read more
Concatenate all results of a stream into a single extendable destination, returning a future representing the end result. Read more
fn concat(self) -> Concat<Self> where
Self::Item: Extend<<Self::Item as IntoIterator>::Item>,
Self::Item: IntoIterator,
fn concat(self) -> Concat<Self> where
Self::Item: Extend<<Self::Item as IntoIterator>::Item>,
Self::Item: IntoIterator,
please use Stream::concat2
instead
Concatenate all results of a stream into a single extendable destination, returning a future representing the end result. Read more
fn fold<F, T, Fut>(self, init: T, f: F) -> Fold<Self, F, Fut, T> where
F: FnMut(T, Self::Item) -> Fut,
Fut: IntoFuture<Item = T>,
Self::Error: From<<Fut as IntoFuture>::Error>,
fn fold<F, T, Fut>(self, init: T, f: F) -> Fold<Self, F, Fut, T> where
F: FnMut(T, Self::Item) -> Fut,
Fut: IntoFuture<Item = T>,
Self::Error: From<<Fut as IntoFuture>::Error>,
Execute an accumulating computation over a stream, collecting all the values into one final result. Read more
Flattens a stream of streams into just one continuous stream. Read more
fn skip_while<P, R>(self, pred: P) -> SkipWhile<Self, P, R> where
R: IntoFuture<Item = bool, Error = Self::Error>,
P: FnMut(&Self::Item) -> R,
fn skip_while<P, R>(self, pred: P) -> SkipWhile<Self, P, R> where
R: IntoFuture<Item = bool, Error = Self::Error>,
P: FnMut(&Self::Item) -> R,
Skip elements on this stream while the predicate provided resolves to
true
. Read more
fn take_while<P, R>(self, pred: P) -> TakeWhile<Self, P, R> where
R: IntoFuture<Item = bool, Error = Self::Error>,
P: FnMut(&Self::Item) -> R,
fn take_while<P, R>(self, pred: P) -> TakeWhile<Self, P, R> where
R: IntoFuture<Item = bool, Error = Self::Error>,
P: FnMut(&Self::Item) -> R,
Take elements from this stream while the predicate provided resolves to
true
. Read more
Runs this stream to completion, executing the provided closure for each element on the stream. Read more
Map this stream’s error to any error implementing From
for
this stream’s Error
, returning a new stream. Read more
Creates a new stream of at most amt
items of the underlying stream. Read more
Creates a new stream which skips amt
items of the underlying stream. Read more
Fuse a stream such that poll
will never again be called once it has
finished. Read more
Catches unwinding panics while polling the stream. Read more
fn buffered(self, amt: usize) -> Buffered<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error == Self::Error,
fn buffered(self, amt: usize) -> Buffered<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error == Self::Error,
An adaptor for creating a buffered list of pending futures. Read more
fn buffer_unordered(self, amt: usize) -> BufferUnordered<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error == Self::Error,
fn buffer_unordered(self, amt: usize) -> BufferUnordered<Self> where
Self::Item: IntoFuture,
<Self::Item as IntoFuture>::Error == Self::Error,
An adaptor for creating a buffered list of pending futures (unordered). Read more
functionality provided by select
now
An adapter for merging the output of two streams. Read more
An adapter for zipping two streams together. Read more
Adapter for chaining two stream. Read more
An adaptor for chunking up items of the stream inside a vector. Read more
Creates a stream that selects the next element from either this stream or the provided one, whichever is ready first. Read more
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
Splits this Stream + Sink
object into separate Stream
and Sink
objects. Read more
Do something with each item of this stream, afterwards passing it on. Read more
Do something with the error of this stream, afterwards passing it on. Read more
Write a buffer into this writer, returning how many bytes were written. Read more
Flush this output stream, ensuring that all intermediately buffered contents reach their destination. Read more
can_vector
)Determines if this Write
r has an efficient write_vectored
implementation. Read more
Attempts to write an entire buffer into this writer. Read more
write_all_vectored
)Attempts to write multiple buffers into this writer. Read more
Writes a formatted string into this writer, returning any error encountered. Read more
Auto Trait Implementations
impl<T> RefUnwindSafe for Compat<T> where
T: RefUnwindSafe,
impl<T> UnwindSafe for Compat<T> where
T: UnwindSafe,
Blanket Implementations
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
Converts a tokio-io AsyncWrite
into a futures-io 0.3
AsyncWrite
. Read more
Mutably borrows from an owned value. Read more
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
Converts a futures 0.1
Future<Item = T, Error = E>
into a futures 0.3
Future<Output = Result<T, E>>
. Read more
Reads an unsigned 8 bit integer from the underlying reader. Read more
Reads a signed 8 bit integer from the underlying reader. Read more
Reads an unsigned 16 bit integer from the underlying reader. Read more
Reads a signed 16 bit integer from the underlying reader. Read more
Reads an unsigned 24 bit integer from the underlying reader. Read more
Reads a signed 24 bit integer from the underlying reader. Read more
Reads an unsigned 32 bit integer from the underlying reader. Read more
Reads a signed 32 bit integer from the underlying reader. Read more
Reads an unsigned 48 bit integer from the underlying reader. Read more
Reads a signed 48 bit integer from the underlying reader. Read more
Reads an unsigned 64 bit integer from the underlying reader. Read more
Reads a signed 64 bit integer from the underlying reader. Read more
Reads an unsigned 128 bit integer from the underlying reader. Read more
Reads a signed 128 bit integer from the underlying reader. Read more
Reads an unsigned n-bytes integer from the underlying reader. Read more
Reads a signed n-bytes integer from the underlying reader. Read more
fn read_uint128<T>(&mut self, nbytes: usize) -> Result<u128, Error> where
T: ByteOrder,
fn read_uint128<T>(&mut self, nbytes: usize) -> Result<u128, Error> where
T: ByteOrder,
Reads an unsigned n-bytes integer from the underlying reader.
fn read_int128<T>(&mut self, nbytes: usize) -> Result<i128, Error> where
T: ByteOrder,
fn read_int128<T>(&mut self, nbytes: usize) -> Result<i128, Error> where
T: ByteOrder,
Reads a signed n-bytes integer from the underlying reader.
Reads a IEEE754 single-precision (4 bytes) floating point number from the underlying reader. Read more
Reads a IEEE754 double-precision (8 bytes) floating point number from the underlying reader. Read more
Reads a sequence of unsigned 16 bit integers from the underlying reader. Read more
Reads a sequence of unsigned 32 bit integers from the underlying reader. Read more
Reads a sequence of unsigned 64 bit integers from the underlying reader. Read more
Reads a sequence of unsigned 128 bit integers from the underlying reader. Read more
Reads a sequence of signed 8 bit integers from the underlying reader. Read more
Reads a sequence of signed 16 bit integers from the underlying reader. Read more
Reads a sequence of signed 32 bit integers from the underlying reader. Read more
Reads a sequence of signed 64 bit integers from the underlying reader. Read more
Reads a sequence of signed 128 bit integers from the underlying reader. Read more
Reads a sequence of IEEE754 single-precision (4 bytes) floating point numbers from the underlying reader. Read more
Reads a sequence of IEEE754 double-precision (8 bytes) floating point numbers from the underlying reader. Read more
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
fn compat(self) -> Compat01As03<Self>ⓘNotable traits for Compat01As03<Fut>impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
impl<Fut> Future for Compat01As03<Fut> where
Fut: Future, type Output = Result<<Fut as Future>::Item, <Fut as Future>::Error>;
Converts a futures 0.1
Stream<Item = T, Error = E>
into a futures 0.3
Stream<Item = Result<T, E>>
. Read more
Writes an unsigned 8 bit integer to the underlying writer. Read more
Writes a signed 8 bit integer to the underlying writer. Read more
Writes an unsigned 16 bit integer to the underlying writer. Read more
Writes a signed 16 bit integer to the underlying writer. Read more
Writes an unsigned 24 bit integer to the underlying writer. Read more
Writes a signed 24 bit integer to the underlying writer. Read more
Writes an unsigned 32 bit integer to the underlying writer. Read more
Writes a signed 32 bit integer to the underlying writer. Read more
Writes an unsigned 48 bit integer to the underlying writer. Read more
Writes a signed 48 bit integer to the underlying writer. Read more
Writes an unsigned 64 bit integer to the underlying writer. Read more
Writes a signed 64 bit integer to the underlying writer. Read more
fn write_u128<T>(&mut self, n: u128) -> Result<(), Error> where
T: ByteOrder,
fn write_u128<T>(&mut self, n: u128) -> Result<(), Error> where
T: ByteOrder,
Writes an unsigned 128 bit integer to the underlying writer.
fn write_i128<T>(&mut self, n: i128) -> Result<(), Error> where
T: ByteOrder,
fn write_i128<T>(&mut self, n: i128) -> Result<(), Error> where
T: ByteOrder,
Writes a signed 128 bit integer to the underlying writer.
Writes an unsigned n-bytes integer to the underlying writer. Read more
Writes a signed n-bytes integer to the underlying writer. Read more
Writes an unsigned n-bytes integer to the underlying writer. Read more
Writes a signed n-bytes integer to the underlying writer. Read more
Writes a IEEE754 single-precision (4 bytes) floating point number to the underlying writer. Read more