pub(crate) struct FullPublicationQueue {
pending: SyncMutex<Vec<FullPublication>>,
}Expand description
Queue receiving notifications after a holder publishes ChunkStatus::Full.
ChunkMap owns the queue strongly. Holders keep only a weak sink so an
unloading holder cannot retain its map.
Fields§
§pending: SyncMutex<Vec<FullPublication>>Implementations§
Source§impl FullPublicationQueue
impl FullPublicationQueue
pub(crate) fn publish(&self, holder: &Arc<ChunkHolder>)
pub(crate) fn drain(&self) -> Vec<FullPublication>
Trait Implementations§
Source§impl Default for FullPublicationQueue
impl Default for FullPublicationQueue
Source§fn default() -> FullPublicationQueue
fn default() -> FullPublicationQueue
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !Freeze for FullPublicationQueue
impl !RefUnwindSafe for FullPublicationQueue
impl !UnwindSafe for FullPublicationQueue
impl Send for FullPublicationQueue
impl Sync for FullPublicationQueue
impl Unpin for FullPublicationQueue
impl UnsafeUnpin for FullPublicationQueue
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
§impl<T> Instrument for T
impl<T> Instrument for T
§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreWraps this value in an
Arc<SyncMutex<>>