结构体 WeakSender 

pub struct WeakSender<T> { /* 私有字段 */ }

不会阻止通道被关闭的 sender。

如果 channel 的所有 Sender 实例都已被 drop，仅剩下 WeakSender 实例，则 channel 关闭。

为了发送消息，WeakSender 需要使用 WeakSender::upgrade 进行升级，该函数返回 Option<Sender>。如果所有 Sender 都已被 drop，则返回 None，否则返回 Sender。

示例

use tokio::sync::broadcast::channel;

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

// 升级会成功，因为 `tx` 仍然存在。
assert!(tx_weak.upgrade().is_some());

// 如果 drop 掉 `tx`，则升级会失败。
drop(tx);
assert!(tx_weak.clone().upgrade().is_none());

实现

impl<T> WeakSender<T>

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

尝试将 WeakSender 转换为 Sender。

如果存在其他存活的 Sender 实例且 channel 之前未被 drop，则返回 Some，否则返回 None。

pub fn strong_count(&self) -> usize

返回 Sender 句柄的数量。

pub fn weak_count(&self) -> usize

返回 WeakSender 句柄的数量。

trait 实现

impl<T> Clone for WeakSender<T>

fn clone(&self) -> WeakSender<T>

返回值的副本。 更多信息

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

Performs copy-assignment from source. 更多信息

impl<T> Debug for WeakSender<T>

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

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

impl<T> Drop for WeakSender<T>

fn drop(&mut self)

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