pub struct BucketsThreadDispatcher<B: LockFreeBucket, S: BucketItemSerializer> { /* private fields */ }
Implementations§
Source§impl<B: LockFreeBucket, S: BucketItemSerializer> BucketsThreadDispatcher<B, S>
impl<B: LockFreeBucket, S: BucketItemSerializer> BucketsThreadDispatcher<B, S>
pub fn new( mtb: &Arc<MultiThreadBuckets<B>>, thread_data: BucketsThreadBuffer, deserializer_init_data: S::InitData, ) -> Self
pub fn add_element_extended( &mut self, bucket: u16, extra_data: &S::ExtraData, extra_data_buffer: &S::ExtraDataBuffer, element: &S::InputElementType<'_>, ) -> ChunkingStatus
pub fn add_element(
&mut self,
bucket: u16,
extra_data: &S::ExtraData,
element: &S::InputElementType<'_>,
)where
S: BucketItemSerializer<ExtraDataBuffer = ()>,
pub fn finalize(self) -> (BucketsThreadBuffer, Arc<MultiThreadBuckets<B>>)
Auto Trait Implementations§
impl<B, S> Freeze for BucketsThreadDispatcher<B, S>
impl<B, S> !RefUnwindSafe for BucketsThreadDispatcher<B, S>
impl<B, S> Send for BucketsThreadDispatcher<B, S>where
S: Send,
impl<B, S> Sync for BucketsThreadDispatcher<B, S>where
S: Sync,
impl<B, S> Unpin for BucketsThreadDispatcher<B, S>where
S: Unpin,
impl<B, S> !UnwindSafe for BucketsThreadDispatcher<B, S>
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
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 more