Структура WeakUnboundedSender

Неограниченный отправитель, который не препятствует закрытию канала.

Если все экземпляры UnboundedSender канала были удалены и остались только экземпляры WeakUnboundedSender, канал закрывается.

Чтобы отправлять сообщения, необходимо повысить уровень WeakUnboundedSender с помощью WeakUnboundedSender::upgrade, которая возвращает Option<UnboundedSender>. Она возвращает None, если все UnboundedSenders были удалены; в противном случае она возвращает 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());