结构体 WeakUnboundedSender 

pub struct WeakUnboundedSender<T> { /* private fields */ }

一个无界 sender，不会阻止 channel 被关闭。

如果通道的所有 UnboundedSender 实例 都已被丢弃， 且仅剩 WeakUnboundedSender 实例， 则该通道 被关闭。

为了发送消息， WeakUnboundedSender 需要使用 WeakUnboundedSender::upgrade 进行升级， 它返回 Option<UnboundedSender>。 如果所有 UnboundedSender 都已被丢弃， 则返回 None， 否则返回一个 UnboundedSender。

示例

use tokio::sync::mpsc::unbounded_channel;

let (tx, _rx) = unbounded_channel::<i32>();
let tx_weak = tx.downgrade();

// Upgrading will succeed because `tx` still exists.
assert!(tx_weak.upgrade().is_some());

// If we drop `tx`, then it will fail.
drop(tx);
assert!(tx_weak.clone().upgrade().is_none());

实现

impl<T> WeakUnboundedSender<T>

pub fn upgrade(&self) -> Option<UnboundedSender<T>>

尝试将 WeakUnboundedSender 转换为 UnboundedSender。如果还有其他 Sender 实例处于活动状态且通道先前未被丢弃，则返回 Some，否则返回 None。

pub fn strong_count(&self) -> usize

返回 UnboundedSender 句柄的数量。

pub fn weak_count(&self) -> usize

返回 WeakUnboundedSender 句柄的数量。

Trait 实现

impl<T> Clone for WeakUnboundedSender<T>

fn clone(&self) -> Self

返回值的副本。 更多信息

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. 更多信息

impl<T> Debug for WeakUnboundedSender<T>

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

使用给定的格式化器格式化此值。 更多信息

impl<T> Drop for WeakUnboundedSender<T>

fn drop(&mut self)

执行此类型的析构函数。 更多信息