#[must_use = "futures do nothing unless polled"]
pub struct Receiver<T> { /* fields omitted */ }
A future for a value that will be provided by another asynchronous task.
This is created by the channel
function.
Gracefully close this receiver, preventing any subsequent attempts to
send to it.
Any send
operation which happens after this method returns is
guaranteed to fail. After calling this method, you can use
Receiver::poll
to determine whether a
message had previously been sent.
Attempts to receive a message outside of the context of a task.
Useful when a Context
is not available
such as within a Drop
impl.
Does not schedule a task wakeup or have any other side effects.
A return value of None
must be considered immediately stale (out of
date) unless close
has been called first.
Returns an error if the sender was dropped.
🔬 This is a nightly-only experimental API. (futures_api
)
futures in libcore are unstable
The result of the Future
.
🔬 This is a nightly-only experimental API. (futures_api
)
futures in libcore are unstable
Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available. Read more
Executes the destructor for this type. Read more
Formats the value using the given formatter. Read more
🔬 This is a nightly-only experimental API. (try_from
)
The type returned in the event of a conversion error.
🔬 This is a nightly-only experimental API. (try_from
)
🔬 This is a nightly-only experimental API. (try_from
)
The type returned in the event of a conversion error.
🔬 This is a nightly-only experimental API. (try_from
)
Immutably borrows from an owned value. Read more
[+]
[+]
[−]
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
[+]
[−]
Map this future's output to a different type, returning a new future of the resulting type. Read more
[−]
Chain on a computation for when a future finished, passing the result of the future to the provided closure f
. Read more
[−]
Joins the result of two futures, waiting for them both to complete. Read more
[−]
Same as join
, but with more futures. Read more
fn join4<Fut2, Fut3, Fut4>( self, future2: Fut2, future3: Fut3, future4: Fut4 ) -> Join4<Self, Fut2, Fut3, Fut4> where Fut2: Future, Fut3: Future + Future, Fut4: Future, | [src] |
[−]
Same as join
, but with more futures. Read more
fn join5<Fut2, Fut3, Fut4, Fut5>( self, future2: Fut2, future3: Fut3, future4: Fut4, future5: Fut5 ) -> Join5<Self, Fut2, Fut3, Fut4, Fut5> where Fut2: Future, Fut3: Future + Future, Fut4: Future, Fut5: Future, | [src] |
[−]
Same as join
, but with more futures. Read more
[−]
Convert this future into a single element stream. Read more
[−]
Flatten the execution of this future when the successful result of this future is itself another future. Read more
[−]
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 output of a future before 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
[−]
Wrap the future in a Box, pinning it.
[−]
Turns a Future
into a TryFuture
with Error = ()
.
[−]
Assigns the provided Spawn
to be used when spawning tasks from within the future. Read more
[−]
A convenience for calling Future::poll
on Unpin
future types.
[+]
type Ok = T
The type of successful values yielded by this future
type Error = E
The type of failures yielded by this future
[−]
Poll this TryFuture
as if it were a Future
. Read more
[+]
[−]
Flattens the execution of this future when the successful result of this future is a [Sink
]. Read more
[−]
Maps this future's success value to a different value. Read more
[−]
Maps this future's error value to a different value. Read more
[−]
Maps this future's Error
to a new error type using the Into
trait. Read more
[−]
Executes another future after this one resolves successfully. The success value is passed to a closure to create this subsequent future. Read more
[−]
Executes another future if this one resolves to an error. The error value is passed to a closure to create this subsequent future. Read more
[−]
Unwraps this future's ouput, producing a future with this future's Ok
type as its Output
type. Read more
[−]
Wraps a [TryFuture
] into a type that implements Future
. Read more
[−]
Joins the result of two futures, waiting for them both to complete or for one to produce an error. Read more
[−]
Same as try_join
, but with more futures. Read more
fn try_join4<Fut2, Fut3, Fut4>( self, future2: Fut2, future3: Fut3, future4: Fut4 ) -> TryJoin4<Self, Fut2, Fut3, Fut4> where Fut2: TryFuture<Error = Self::Error>, Fut3: TryFuture<Error = Self::Error>, Fut4: TryFuture<Error = Self::Error>, | [src] |
[−]
Same as try_join
, but with more futures. Read more
fn try_join5<Fut2, Fut3, Fut4, Fut5>( self, future2: Fut2, future3: Fut3, future4: Fut4, future5: Fut5 ) -> TryJoin5<Self, Fut2, Fut3, Fut4, Fut5> where Fut2: TryFuture<Error = Self::Error>, Fut3: TryFuture<Error = Self::Error>, Fut4: TryFuture<Error = Self::Error>, Fut5: TryFuture<Error = Self::Error>, | [src] |
[−]
Same as try_join
, but with more futures. Read more