Перечисление TryRecv Error
pub enum TryRecvError {
Empty,
Closed,
Lagged(u64),
}
sync.Варианты
Empty
В данный момент канал пуст. Активные дескрипторы Sender всё ещё существуют, поэтому данные могут появиться.
Closed
Активных отправителей больше нет, а значит, новые сообщения отправляться не будут.
Lagged(u64)
Получатель слишком сильно отстал: одно или несколько сообщений были перезаписаны в кольцевом буфере до того, как этот получатель успел их прочитать.
Получатель остаётся подписанным. Его внутренний курсор перемещён к самому старому сообщению, которое ещё хранится в канале; следующий успешный вызов try_recv вернёт это сообщение (если оно не будет перезаписано новыми отправленными сообщениями).
Значение u64 — это количество пропущенных сообщений (удалённых до предыдущей позиции курсора получателя).
Реализации трейтов
impl Clone for TryRecvError
fn clone(&self) -> TryRecvError
fn clone_from(&mut self, source: &Self)
source. Подробнее
impl Debug for TryRecvError
impl Display for TryRecvError
impl Eq for TryRecvError
impl Error for TryRecvError
fn source(&self) -> Option<&(dyn Error + 'static)>
fn description(&self) -> &str
используйте реализацию Display или to_string()
impl PartialEq for TryRecvError
impl StructuralPartialEq for TryRecvError
Автоматические реализации трейтов
impl Freeze for TryRecvError
impl RefUnwindSafe for TryRecvError
impl Send for TryRecvError
impl Sync for TryRecvError
impl Unpin for TryRecvError
impl UnsafeUnpin for TryRecvError
impl UnwindSafe for TryRecvError
Обобщённые реализации
impl<T> BorrowMut<T> for Twhere T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
impl<T> CloneToUninit for Twhere T: Clone,
unsafe fn clone_to_uninit(&self, dest: *mut u8)
clone_to_uninit)
impl<T> Instrument for T
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
impl<T> ToOwned for Twhere T: Clone,
type Owned = T
fn to_owned(&self) -> T
fn clone_into(&self, target: &mut T)
impl<T> WithSubscriber for T
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
Subscriber к этому типу и возвращает обёртку WithDispatch. Подробнее
MIT License
Copyright © Tokio Contributors
https://docs.rs/tokio/1.53.1/tokio/sync/broadcast/error/enum.TryRecvError.html