pub struct AsyncDetachedWorkIter<B: MutRB> { /* private fields */ }
Expand description
Async version of DetachedWorkIter
.
Implementations§
source§impl<B: MutRB<Item = T>, T> AsyncDetachedWorkIter<B>
impl<B: MutRB<Item = T>, T> AsyncDetachedWorkIter<B>
pub fn from_sync(work: DetachedWorkIter<B>) -> AsyncDetachedWorkIter<B>
pub fn into_sync(self) -> DetachedWorkIter<B>
sourcepub fn attach(self) -> AsyncWorkIter<B>
pub fn attach(self) -> AsyncWorkIter<B>
Same as DetachedWorkIter::attach
.
sourcepub fn is_prod_alive(&self) -> bool
pub fn is_prod_alive(&self) -> bool
Same as DetachedWorkIter::is_prod_alive
.
sourcepub fn is_cons_alive(&self) -> bool
pub fn is_cons_alive(&self) -> bool
Same as DetachedWorkIter::is_cons_alive
.
sourcepub fn index(&self) -> usize
pub fn index(&self) -> usize
Same as DetachedWorkIter::index
.
sourcepub fn available(&mut self) -> usize
pub fn available(&mut self) -> usize
Same as DetachedWorkIter::available
.
sourcepub fn get_workable(&mut self) -> GetWorkableFuture<'_, B, T> ⓘ
pub fn get_workable(&mut self) -> GetWorkableFuture<'_, B, T> ⓘ
Same as DetachedWorkIter::get_workable
.
sourcepub fn get_workable_slice_exact(
&mut self,
count: usize
) -> GetWorkableSliceExactFuture<'_, B, T> ⓘ
pub fn get_workable_slice_exact( &mut self, count: usize ) -> GetWorkableSliceExactFuture<'_, B, T> ⓘ
sourcepub fn get_workable_slice_avail(
&mut self
) -> GetWorkableSliceAvailFuture<'_, B, T> ⓘ
pub fn get_workable_slice_avail( &mut self ) -> GetWorkableSliceAvailFuture<'_, B, T> ⓘ
sourcepub fn get_workable_slice_multiple_of(
&mut self,
rhs: usize
) -> GetWorkableSliceMultipleOfFuture<'_, B, T> ⓘ
pub fn get_workable_slice_multiple_of( &mut self, rhs: usize ) -> GetWorkableSliceMultipleOfFuture<'_, B, T> ⓘ
sourcepub fn sync_index(&self)
pub fn sync_index(&self)
Same as DetachedWorkIter::sync_index
.
Trait Implementations§
impl<B: ConcurrentRB + MutRB<Item = T>, T> Send for AsyncDetachedWorkIter<B>
Auto Trait Implementations§
impl<B> Freeze for AsyncDetachedWorkIter<B>
impl<B> RefUnwindSafe for AsyncDetachedWorkIter<B>where
B: RefUnwindSafe,
impl<B> !Sync for AsyncDetachedWorkIter<B>
impl<B> Unpin for AsyncDetachedWorkIter<B>
impl<B> UnwindSafe for AsyncDetachedWorkIter<B>where
B: RefUnwindSafe,
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