pub struct InboxInstall {
pub budget: Arc<ConnectionInboxBudget>,
pub depth_cap: usize,
pub notifier: Option<InboxNotifier>,
}Expand description
Everything a server connection installs onto a subscription’s inbox.
Carries the shared §5 byte budget, the per-inbox fairness cap, and the R3 wake notifier. Passed INTO the subscribe call so the installation happens at inbox construction — strictly BEFORE the registration is published to the channel actor — closing the pre-install window in which envelopes could be admitted uncharged or without a wake.
Fields§
§budget: Arc<ConnectionInboxBudget>Shared per-connection byte budget (§5).
depth_cap: usizePer-inbox envelope-count fairness trip (§5).
notifier: Option<InboxNotifier>R3 wake notifier fired on the inbox’s empty→non-empty transition. None
when the caller has no waker (scheduler-free unit tests).
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for InboxInstall
impl !UnwindSafe for InboxInstall
impl Freeze for InboxInstall
impl Send for InboxInstall
impl Sync for InboxInstall
impl Unpin for InboxInstall
impl UnsafeUnpin for InboxInstall
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more