pub(super) struct SingleRuntime {
queue: VecDeque<PlannedChunk>,
run: AggregateRun,
}Fields§
§queue: VecDeque<PlannedChunk>§run: AggregateRunImplementations§
Source§impl SingleRuntime
impl SingleRuntime
pub(super) fn new(chunk_iterations: &[u32]) -> Self
pub(super) fn next_work( &mut self, max_items: usize, next_item_id: &mut u64, ) -> Vec<RuntimeWorkItem>
pub(super) fn ingest( &mut self, results: &[RuntimeWorkResult], ) -> Result<(), StrategyError>
pub(super) fn is_complete(&self) -> bool
pub(super) fn has_pending(&self) -> bool
pub(super) fn peek_shape(&self) -> (u32, bool)
pub(super) fn finalize(&self) -> Result<FinalOutput, StrategyError>
Trait Implementations§
Auto Trait Implementations§
impl Freeze for SingleRuntime
impl RefUnwindSafe for SingleRuntime
impl Send for SingleRuntime
impl Sync for SingleRuntime
impl Unpin for SingleRuntime
impl UnsafeUnpin for SingleRuntime
impl UnwindSafe for SingleRuntime
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>
§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> 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 more