Struct drone_core::sync::spsc::oneshot::Receiver[−][src]

[+] Show declaration

[+] Expand attributes
#[must_use = "futures do nothing unless you `.await` or poll them"]pub struct Receiver<T> { /* fields omitted */ }

[−]

The receiving-half of oneshot::channel.

Implementations

`impl<T> Receiver<T>`[src][−]

`pub fn close(&mut self)`[src][−]

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.

`pub fn try_recv(&mut self) -> Result<Option<T>, Canceled>`[src][−]

Attempts to receive a message outside of the context of a task.

Does not schedule a task wakeup or have any other side effects.

A return value of Ok(None) must be considered immediately stale (out of date) unless close has been called first.

Returns an error if the sender was dropped.

Trait Implementations

`impl<T> Drop for Receiver<T>`[src][+]

[+] Show hidden undocumented items

`fn drop(&mut self)`[src][−]

`impl<T> Future for Receiver<T>`[src][+]

[+] Show hidden undocumented items

`type Output = Result<T, Canceled>`

The type of value produced on completion.

`fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>`[src][−]

Auto Trait Implementations

`impl<T> Send for Receiver<T> where T: Send,`

`impl<T> Sync for Receiver<T> where T: Send,`

`impl<T> Unpin for Receiver<T>`

Blanket Implementations

`impl<T> Any for T where T: 'static + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn type_id(&self) -> TypeId`[src][−]

`impl<T> Borrow<T> for T where T: ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn borrow(&self) -> &T`[src][−]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn borrow_mut(&mut self) -> &mut T`[src][−]

`impl<T> From<T> for T`[src][+]

[+] Show hidden undocumented items

`pub fn from(t: T) -> T`[src][−]

`impl<T> FutureExt for T where T: Future + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn map<U, F>(self, f: F) -> Map<Self, F> where F: FnOnce(Self::Output) -> U,` [src][−]

`pub fn map_into(self) -> MapInto<Self, U> where Self::Output: Into,` [src][−]

`pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where F: FnOnce(Self::Output) -> Fut, Fut: Future,` [src][−]

`pub fn left_future(self) -> Either<Self, B> where B: Future<Output = Self::Output>,` [src][−]

`pub fn right_future<A>(self) -> Either<A, Self> where A: Future<Output = Self::Output>,` [src][−]

`pub fn into_stream(self) -> IntoStream<Self>`[src][−]

`pub fn flatten(self) -> Flatten<Self> where Self::Output: Future,` [src][−]

`pub fn flatten_stream(self) -> FlattenStream<Self> where Self::Output: Stream,` [src][−]

`pub fn fuse(self) -> Fuse<Self>`[src][−]

`pub fn inspect<F>(self, f: F) -> Inspect<Self, F> where F: FnOnce(&Self::Output),` [src][−]

`pub fn boxed<'a>( self ) -> Pin<Box<dyn Future<Output = Self::Output> + 'a + Send, Global>> where Self: Send + 'a,` [src][−]

`pub fn boxed_local<'a>( self ) -> Pin<Box<dyn Future<Output = Self::Output> + 'a, Global>> where Self: 'a,` [src][−]

`pub fn unit_error(self) -> UnitError<Self>`[src][−]

`pub fn never_error(self) -> NeverError<Self>`[src][−]

`pub fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output> where Self: Unpin,` [src][−]

`pub fn now_or_never(self) -> Option<Self::Output>`[src][−]

`impl<T, U> Into for T where U: From<T>,` [src][+]

[+] Show hidden undocumented items

`pub fn into(self) -> U`[src][−]

`impl<F> IntoFuture for F where F: Future,` [src][+]

[+] Show hidden undocumented items

`type Output = <F as Future>::Output`

🔬 This is a nightly-only experimental API. (into_future)

The output that the future will produce on completion.

`type Future = F`

🔬 This is a nightly-only experimental API. (into_future)

Which kind of future are we turning this into?

`pub fn into_future(self) -> <F as IntoFuture>::Future`[src][−]

`impl<T> Same<T> for T`[src]

`type Output = T`

Should always be Self

`impl<T, U> TryFrom for T where U: Into<T>,` [src][+]

[+] Show hidden undocumented items

`type Error = Infallible`

The type returned in the event of a conversion error.

`pub fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>`[src][−]

`impl<F, T, E> TryFuture for F where F: Future<Output = Result<T, E>> + ?Sized,` [src][+]

[+] Show hidden undocumented items

`type Ok = T`

The type of successful values yielded by this future

`type Error = E`

The type of failures yielded by this future

`pub fn try_poll( self: Pin<&mut F>, cx: &mut Context<'_> ) -> Poll<<F as Future>::Output>`[src][−]

`impl<Fut> TryFutureExt for Fut where Fut: TryFuture + ?Sized,` [src][+]

[+] Show hidden undocumented items

`pub fn flatten_sink<Item>(self) -> FlattenSink<Self, Self::Ok> where Self::Ok: Sink<Item>, <Self::Ok as Sink<Item>>::Error == Self::Error,` [src][−]

`pub fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> where F: FnOnce(Self::Ok) -> T,` [src][−]

`pub fn map_ok_or_else<T, E, F>(self, e: E, f: F) -> MapOkOrElse<Self, F, E> where F: FnOnce(Self::Ok) -> T, E: FnOnce(Self::Error) -> T,` [src][−]

`pub fn map_err<E, F>(self, f: F) -> MapErr<Self, F> where F: FnOnce(Self::Error) -> E,` [src][−]

`pub fn err_into<E>(self) -> ErrInto<Self, E> where Self::Error: Into<E>,` [src][−]

`pub fn ok_into(self) -> OkInto<Self, U> where Self::Ok: Into,` [src][−]

`pub fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F> where F: FnOnce(Self::Ok) -> Fut, Fut: TryFuture<Error = Self::Error>,` [src][−]

`pub fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F> where F: FnOnce(Self::Error) -> Fut, Fut: TryFuture<Ok = Self::Ok>,` [src][−]

`pub fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F> where F: FnOnce(&Self::Ok),` [src][−]

`pub fn inspect_err<F>(self, f: F) -> InspectErr<Self, F> where F: FnOnce(&Self::Error),` [src][−]

`pub fn try_flatten(self) -> TryFlatten<Self, Self::Ok> where Self::Ok: TryFuture, <Self::Ok as TryFuture>::Error == Self::Error,` [src][−]

`pub fn try_flatten_stream(self) -> TryFlattenStream<Self> where Self::Ok: TryStream, <Self::Ok as TryStream>::Error == Self::Error,` [src][−]

`pub fn unwrap_or_else<F>(self, f: F) -> UnwrapOrElse<Self, F> where F: FnOnce(Self::Error) -> Self::Ok,` [src][−]

`pub fn into_future(self) -> IntoFuture<Self>`[src][−]

`pub fn try_poll_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Self::Ok, Self::Error>> where Self: Unpin,` [src][−]

`impl<T, U> TryInto for T where U: TryFrom<T>,` [src][+]

[+] Show hidden undocumented items

`type Error = >::Error`

The type returned in the event of a conversion error.

Struct drone_core::sync::spsc::oneshot::Receiver[−][src]

Implementations

impl<T> Receiver<T>[src][−]

pub fn close(&mut self)[src][−]

pub fn try_recv(&mut self) -> Result<Option<T>, Canceled>[src][−]

Trait Implementations

impl<T> Drop for Receiver<T>[src][+]

fn drop(&mut self)[src][−]

impl<T> Future for Receiver<T>[src][+]

type Output = Result<T, Canceled>

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>[src][−]

Auto Trait Implementations

impl<T> Send for Receiver<T> where T: Send,

impl<T> Sync for Receiver<T> where T: Send,

impl<T> Unpin for Receiver<T>

Blanket Implementations

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

pub fn type_id(&self) -> TypeId[src][−]

impl<T> Borrow<T> for T where T: ?Sized, [src][+]

pub fn borrow(&self) -> &T[src][−]

impl<T> BorrowMut<T> for T where T: ?Sized, [src][+]

pub fn borrow_mut(&mut self) -> &mut T[src][−]

impl<T> From<T> for T[src][+]

pub fn from(t: T) -> T[src][−]

impl<T> FutureExt for T where T: Future + ?Sized, [src][+]

pub fn map<U, F>(self, f: F) -> Map<Self, F> where F: FnOnce(Self::Output) -> U, [src][−]

pub fn map_into<U>(self) -> MapInto<Self, U> where Self::Output: Into<U>, [src][−]

pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where F: FnOnce(Self::Output) -> Fut, Fut: Future, [src][−]

pub fn left_future<B>(self) -> Either<Self, B> where B: Future<Output = Self::Output>, [src][−]

pub fn right_future<A>(self) -> Either<A, Self> where A: Future<Output = Self::Output>, [src][−]

pub fn into_stream(self) -> IntoStream<Self>[src][−]

pub fn flatten(self) -> Flatten<Self> where Self::Output: Future, [src][−]

pub fn flatten_stream(self) -> FlattenStream<Self> where Self::Output: Stream, [src][−]

pub fn fuse(self) -> Fuse<Self>[src][−]

pub fn inspect<F>(self, f: F) -> Inspect<Self, F> where F: FnOnce(&Self::Output), [src][−]

pub fn boxed<'a>( self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a + Send, Global>> where Self: Send + 'a, [src][−]

pub fn boxed_local<'a>( self) -> Pin<Box<dyn Future<Output = Self::Output> + 'a, Global>> where Self: 'a, [src][−]

pub fn unit_error(self) -> UnitError<Self>[src][−]

pub fn never_error(self) -> NeverError<Self>[src][−]

pub fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output> where Self: Unpin, [src][−]

pub fn now_or_never(self) -> Option<Self::Output>[src][−]

impl<T, U> Into<U> for T where U: From<T>, [src][+]

pub fn into(self) -> U[src][−]

impl<F> IntoFuture for F where F: Future, [src][+]

type Output = <F as Future>::Output

type Future = F

pub fn into_future(self) -> <F as IntoFuture>::Future[src][−]

impl<T> Same<T> for T[src]

type Output = T

impl<T, U> TryFrom<U> for T where U: Into<T>, [src][+]

type Error = Infallible

pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>[src][−]

impl<F, T, E> TryFuture for F where F: Future<Output = Result<T, E>> + ?Sized, [src][+]

type Ok = T

type Error = E

pub fn try_poll( self: Pin<&mut F>, cx: &mut Context<'_>) -> Poll<<F as Future>::Output>[src][−]

impl<Fut> TryFutureExt for Fut where Fut: TryFuture + ?Sized, [src][+]

pub fn flatten_sink<Item>(self) -> FlattenSink<Self, Self::Ok> where Self::Ok: Sink<Item>, <Self::Ok as Sink<Item>>::Error == Self::Error, [src][−]

pub fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> where F: FnOnce(Self::Ok) -> T, [src][−]

pub fn map_ok_or_else<T, E, F>(self, e: E, f: F) -> MapOkOrElse<Self, F, E> where F: FnOnce(Self::Ok) -> T, E: FnOnce(Self::Error) -> T, [src][−]

pub fn map_err<E, F>(self, f: F) -> MapErr<Self, F> where F: FnOnce(Self::Error) -> E, [src][−]

pub fn err_into<E>(self) -> ErrInto<Self, E> where Self::Error: Into<E>, [src][−]

pub fn ok_into<U>(self) -> OkInto<Self, U> where Self::Ok: Into<U>, [src][−]

pub fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F> where F: FnOnce(Self::Ok) -> Fut, Fut: TryFuture<Error = Self::Error>, [src][−]

pub fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F> where F: FnOnce(Self::Error) -> Fut, Fut: TryFuture<Ok = Self::Ok>, [src][−]

pub fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F> where F: FnOnce(&Self::Ok), [src][−]

pub fn inspect_err<F>(self, f: F) -> InspectErr<Self, F> where F: FnOnce(&Self::Error), [src][−]

pub fn try_flatten(self) -> TryFlatten<Self, Self::Ok> where Self::Ok: TryFuture, <Self::Ok as TryFuture>::Error == Self::Error, [src][−]

pub fn try_flatten_stream(self) -> TryFlattenStream<Self> where Self::Ok: TryStream, <Self::Ok as TryStream>::Error == Self::Error, [src][−]

pub fn unwrap_or_else<F>(self, f: F) -> UnwrapOrElse<Self, F> where F: FnOnce(Self::Error) -> Self::Ok, [src][−]

pub fn into_future(self) -> IntoFuture<Self>[src][−]

pub fn try_poll_unpin( &mut self, cx: &mut Context<'_>) -> Poll<Result<Self::Ok, Self::Error>> where Self: Unpin, [src][−]

impl<T, U> TryInto<U> for T where U: TryFrom<T>, [src][+]

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

pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>[src][−]

`impl<T> Receiver<T>`[src][−]

`pub fn close(&mut self)`[src][−]

`pub fn try_recv(&mut self) -> Result<Option<T>, Canceled>`[src][−]

`impl<T> Drop for Receiver<T>`[src][+]

`fn drop(&mut self)`[src][−]

`impl<T> Future for Receiver<T>`[src][+]

`type Output = Result<T, Canceled>`

`fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output>`[src][−]

`impl<T> Send for Receiver<T> where T: Send,`

`impl<T> Sync for Receiver<T> where T: Send,`

`impl<T> Unpin for Receiver<T>`

`impl<T> Any for T where T: 'static + ?Sized,` [src][+]

`pub fn type_id(&self) -> TypeId`[src][−]

`impl<T> Borrow<T> for T where T: ?Sized,` [src][+]

`pub fn borrow(&self) -> &T`[src][−]

`impl<T> BorrowMut<T> for T where T: ?Sized,` [src][+]

`pub fn borrow_mut(&mut self) -> &mut T`[src][−]

`impl<T> From<T> for T`[src][+]

`pub fn from(t: T) -> T`[src][−]

`impl<T> FutureExt for T where T: Future + ?Sized,` [src][+]

`pub fn map<U, F>(self, f: F) -> Map<Self, F> where F: FnOnce(Self::Output) -> U,` [src][−]

`pub fn map_into<U>(self) -> MapInto<Self, U> where Self::Output: Into<U>,` [src][−]

`pub fn then<Fut, F>(self, f: F) -> Then<Self, Fut, F> where F: FnOnce(Self::Output) -> Fut, Fut: Future,` [src][−]

`pub fn left_future<B>(self) -> Either<Self, B> where B: Future<Output = Self::Output>,` [src][−]

`pub fn right_future<A>(self) -> Either<A, Self> where A: Future<Output = Self::Output>,` [src][−]

`pub fn into_stream(self) -> IntoStream<Self>`[src][−]

`pub fn flatten(self) -> Flatten<Self> where Self::Output: Future,` [src][−]

`pub fn flatten_stream(self) -> FlattenStream<Self> where Self::Output: Stream,` [src][−]

`pub fn fuse(self) -> Fuse<Self>`[src][−]

`pub fn inspect<F>(self, f: F) -> Inspect<Self, F> where F: FnOnce(&Self::Output),` [src][−]

`pub fn boxed<'a>( self ) -> Pin<Box<dyn Future<Output = Self::Output> + 'a + Send, Global>> where Self: Send + 'a,` [src][−]

`pub fn boxed_local<'a>( self ) -> Pin<Box<dyn Future<Output = Self::Output> + 'a, Global>> where Self: 'a,` [src][−]

`pub fn unit_error(self) -> UnitError<Self>`[src][−]

`pub fn never_error(self) -> NeverError<Self>`[src][−]

`pub fn poll_unpin(&mut self, cx: &mut Context<'_>) -> Poll<Self::Output> where Self: Unpin,` [src][−]

`pub fn now_or_never(self) -> Option<Self::Output>`[src][−]

`impl<T, U> Into<U> for T where U: From<T>,` [src][+]

`pub fn into(self) -> U`[src][−]

`impl<F> IntoFuture for F where F: Future,` [src][+]

`type Output = <F as Future>::Output`

`type Future = F`

`pub fn into_future(self) -> <F as IntoFuture>::Future`[src][−]

`impl<T> Same<T> for T`[src]

`type Output = T`

`impl<T, U> TryFrom<U> for T where U: Into<T>,` [src][+]

`type Error = Infallible`

`pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>`[src][−]

`impl<F, T, E> TryFuture for F where F: Future<Output = Result<T, E>> + ?Sized,` [src][+]

`type Ok = T`

`type Error = E`

`pub fn try_poll( self: Pin<&mut F>, cx: &mut Context<'_> ) -> Poll<<F as Future>::Output>`[src][−]

`impl<Fut> TryFutureExt for Fut where Fut: TryFuture + ?Sized,` [src][+]

`pub fn flatten_sink<Item>(self) -> FlattenSink<Self, Self::Ok> where Self::Ok: Sink<Item>, <Self::Ok as Sink<Item>>::Error == Self::Error,` [src][−]

`pub fn map_ok<T, F>(self, f: F) -> MapOk<Self, F> where F: FnOnce(Self::Ok) -> T,` [src][−]

`pub fn map_ok_or_else<T, E, F>(self, e: E, f: F) -> MapOkOrElse<Self, F, E> where F: FnOnce(Self::Ok) -> T, E: FnOnce(Self::Error) -> T,` [src][−]

`pub fn map_err<E, F>(self, f: F) -> MapErr<Self, F> where F: FnOnce(Self::Error) -> E,` [src][−]

`pub fn err_into<E>(self) -> ErrInto<Self, E> where Self::Error: Into<E>,` [src][−]

`pub fn ok_into<U>(self) -> OkInto<Self, U> where Self::Ok: Into<U>,` [src][−]

`pub fn and_then<Fut, F>(self, f: F) -> AndThen<Self, Fut, F> where F: FnOnce(Self::Ok) -> Fut, Fut: TryFuture<Error = Self::Error>,` [src][−]

`pub fn or_else<Fut, F>(self, f: F) -> OrElse<Self, Fut, F> where F: FnOnce(Self::Error) -> Fut, Fut: TryFuture<Ok = Self::Ok>,` [src][−]

`pub fn inspect_ok<F>(self, f: F) -> InspectOk<Self, F> where F: FnOnce(&Self::Ok),` [src][−]

`pub fn inspect_err<F>(self, f: F) -> InspectErr<Self, F> where F: FnOnce(&Self::Error),` [src][−]

`pub fn try_flatten(self) -> TryFlatten<Self, Self::Ok> where Self::Ok: TryFuture, <Self::Ok as TryFuture>::Error == Self::Error,` [src][−]

`pub fn try_flatten_stream(self) -> TryFlattenStream<Self> where Self::Ok: TryStream, <Self::Ok as TryStream>::Error == Self::Error,` [src][−]

`pub fn unwrap_or_else<F>(self, f: F) -> UnwrapOrElse<Self, F> where F: FnOnce(Self::Error) -> Self::Ok,` [src][−]

`pub fn into_future(self) -> IntoFuture<Self>`[src][−]

`pub fn try_poll_unpin( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Self::Ok, Self::Error>> where Self: Unpin,` [src][−]

`impl<T, U> TryInto<U> for T where U: TryFrom<T>,` [src][+]

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

`pub fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>`[src][−]