Структура UnboundedSender

Пытается отправить сообщение через этот UnboundedSender без блокировки.

Этот метод не помечен как async, поскольку отправка сообщения в неограниченный канал никогда не требует ожидания. Это возможно благодаря бесконечной ёмкости канала, позволяющей операции send завершиться немедленно. В результате метод send можно использовать как в синхронном, так и в асинхронном коде без каких-либо проблем.

Если принимающая сторона канала закрыта — либо в результате вызова close, либо потому, что UnboundedReceiver была удалена, — эта функция возвращает ошибку. Ошибка содержит значение, переданное в send.

Завершается, когда получатель удалён.

Это позволяет отправителям получать уведомление об отмене интереса к создаваемым значениям и немедленно прекращать работу.

Безопасность при отмене

Этот метод безопасен при отмене. После закрытия канал остаётся закрытым навсегда, и все последующие вызовы closed немедленно вернут управление.

Примеры

use tokio::sync::mpsc;

let (tx1, rx) = mpsc::unbounded_channel::<()>();
let tx2 = tx1.clone();
let tx3 = tx1.clone();
let tx4 = tx1.clone();
let tx5 = tx1.clone();
tokio::spawn(async move {
    drop(rx);
});

futures::join!(
    tx1.closed(),
    tx2.closed(),
    tx3.closed(),
    tx4.closed(),
    tx5.closed()
);
println!("Receiver dropped");

Проверяет, закрыт ли канал. Это происходит, когда UnboundedReceiver удалён или когда вызывается метод UnboundedReceiver::close.

let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<()>();
assert!(!tx.is_closed());

let tx2 = tx.clone();
assert!(!tx2.is_closed());

drop(rx);
assert!(tx.is_closed());
assert!(tx2.is_closed());

Возвращает true, если отправители принадлежат одному каналу.

Примеры

let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<()>();
let  tx2 = tx.clone();
assert!(tx.same_channel(&tx2));

let (tx3, rx3) = tokio::sync::mpsc::unbounded_channel::<()>();
assert!(!tx3.same_channel(&tx2));

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

Возвращает количество дескрипторов UnboundedSender.

Возвращает количество дескрипторов WeakUnboundedSender.

Возвращает аргумент без изменений.

Вызывает U::from(self).

Иными словами, это преобразование выполняет то, что выберет реализация From<T> for U.