Struct Receiver 

pub struct Receiver<S: OneshotStorage> { /* private fields */ }

Receiver for one-shot value transfer

Implements Future directly for .await usage.

一次性值传递的接收器

直接实现了 Future，可直接使用 .await

Implementations

impl<S: OneshotStorage> Receiver<S>

pub async fn wait(self) -> Result<S::Value, RecvError>

Wait for value asynchronously

pub fn close(&mut self)

Close the receiver, preventing any future messages from being sent.

Any send operation which happens after this method returns is guaranteed to fail. After calling close, try_recv should be called to receive a value if one was sent before the call to close completed.

关闭接收器，阻止任何将来的消息发送。

在此方法返回后发生的任何 send 操作都保证失败。 调用 close 后，应调用 try_recv 来接收在 close 完成之前发送的值。

pub fn blocking_recv(self) -> Result<S::Value, RecvError>

Blocking receive, waiting for a value to be sent.

This method is intended for use in synchronous code.

Panics

This function panics if called within an asynchronous execution context.

阻塞接收，等待值被发送。

此方法用于同步代码中。

Panics

如果在异步执行上下文中调用此函数，则会 panic。

impl<T: Send> Receiver<GenericStorage<T>>

pub fn try_recv(&mut self) -> Result<T, TryRecvError>

Try to receive a value without blocking

Returns Ok(value) if value is ready, Err(TryRecvError::Empty) if pending, or Err(TryRecvError::Closed) if sender was dropped.

尝试接收值而不阻塞

如果值就绪返回 Ok(value)，如果待处理返回 Err(TryRecvError::Empty)， 如果发送器被丢弃返回 Err(TryRecvError::Closed)

impl<S: State> Receiver<LiteStorage<S>>

pub async fn recv(self) -> Result<S, RecvError>

Receive a value asynchronously

This is equivalent to using .await directly on the receiver

异步接收一个值

这等同于直接在 receiver 上使用 .await

pub fn try_recv(&mut self) -> Result<S, TryRecvError>

Try to receive a value without blocking

Returns Ok(value) if value is ready, Err(TryRecvError::Empty) if pending, or Err(TryRecvError::Closed) if sender was dropped.

尝试接收值而不阻塞

如果值就绪返回 Ok(value)，如果待处理返回 Err(TryRecvError::Empty)， 如果发送器被丢弃返回 Err(TryRecvError::Closed)

Trait Implementations

impl<S: OneshotStorage> Debug for Receiver<S>

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

Formats the value using the given formatter.

impl<S: OneshotStorage> Future for Receiver<S>

type Output = Result<<S as OneshotStorage>::Value, RecvError>

The type of value produced on completion.

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

Attempts to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl<S: OneshotStorage> Unpin for Receiver<S>