Структура WeakSender

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

Доступно только при включённой функции crate sync.

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

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

Чтобы отправлять сообщения, необходимо повысить WeakSender с помощью WeakSender::upgrade, которая возвращает Option<Sender>. Она возвращает None, если все Senders были удалены, а в противном случае возвращает Sender.

Примеры

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

let (tx, _rx) = channel::<i32>(15);
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> WeakSender<T>

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

Пытается преобразовать WeakSender в Sender.

Метод возвращает Some, если существуют другие активные экземпляры Sender и канал не был удалён ранее; в противном случае возвращается None.

pub fn strong_count(&self) -> usize

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

pub fn weak_count(&self) -> usize

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

Реализации трейтов

impl<T> Clone for WeakSender<T>

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

Возвращает копию значения. Подробнее

1.0.0 (const: unstable) ·

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

Выполняет присваивание копированием из source. Подробнее

impl<T> Debug for WeakSender<T>

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

Форматирует значение с помощью указанного форматтера. Подробнее

impl<T> Drop for WeakSender<T>

fn drop(&mut self)

Выполняет деструктор для этого типа. Подробнее

fn pin_drop(self: Pin<&mut Self>)

🔬Это экспериментальный API, доступный только в nightly-сборке. (pin_ergonomics)

Выполняет деструктор для этого типа, но, в отличие от Drop::drop, требует, чтобы self был закреплён. Подробнее

Автоматические реализации трейтов

impl<T> !RefUnwindSafe for WeakSender<T>

impl<T> !UnwindSafe for WeakSender<T>

impl<T> Freeze for WeakSender<T>

impl<T> Send for WeakSender<T>
where T: Send,

impl<T> Sync for WeakSender<T>
where T: Send,

impl<T> Unpin for WeakSender<T>

impl<T> UnsafeUnpin for WeakSender<T>

Общие реализации

impl<T> Any for T
where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

Получает TypeId для self. Подробнее

impl<T> Borrow<T> for T
where T: ?Sized,

fn borrow(&self) -> &T

Неизменяемо заимствует значение из принадлежащего ему значения. Подробнее

impl<T> BorrowMut<T> for T
where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

Изменяемо заимствует значение из принадлежащего ему значения. Подробнее

impl<T> CloneToUninit for T
where T: Clone,

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬Это экспериментальный API, доступный только в nightly-сборке. (clone_to_uninit)

Выполняет копирующее присваивание из self в dest. Подробнее

impl<T> From<T> for T

fn from(t: T) -> T

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

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self> ⓘ

Инструментирует этот тип с помощью указанного Span, возвращая оболочку Instrumented. Подробнее

fn in_current_span(self) -> Instrumented<Self> ⓘ

Инструментирует этот тип с помощью текущего Span, возвращая оболочку Instrumented. Подробнее

impl<T, U> Into for T
where U: From<T>,

fn into(self) -> U

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

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

impl<T> ToOwned for T
where T: Clone,

type Owned = T

Тип, получаемый после перехода во владение.

fn to_owned(&self) -> T

Создаёт принадлежащие данные из заимствованных данных, обычно путём клонирования. Подробнее

fn clone_into(&self, target: &mut T)

Использует заимствованные данные для замены принадлежащих данных, обычно путём клонирования. Подробнее

impl<T, U> TryFrom for T
where U: Into<T>,

type Error = Infallible

Тип, возвращаемый в случае ошибки преобразования.

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Выполняет преобразование.

impl<T, U> TryInto for T
where U: TryFrom<T>,

type Error = >::Error

Тип, возвращаемый при ошибке преобразования.

fn try_into(self) -> Result<U, >::Error>

Выполняет преобразование.

impl<T> WithSubscriber for T

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
where S: Into<Dispatch>,

Присоединяет переданный Subscriber к этому типу и возвращает обёртку WithDispatch. Подробнее

fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ

Присоединяет текущий по умолчанию Subscriber к этому типу и возвращает обёртку WithDispatch. Подробнее