Struct transact::execution::executor::ExecutionTaskSubmitter [−][src]
pub struct ExecutionTaskSubmitter { /* fields omitted */ }Expand description
The interface for submitting execution tasks to the Executor.
Implementations
pub fn submit(
&self,
task_iterator: Box<dyn Iterator<Item = ExecutionTask> + Send>,
notifier: Box<dyn ExecutionTaskCompletionNotifier>
) -> Result<(), ExecutorError>
pub fn submit(
&self,
task_iterator: Box<dyn Iterator<Item = ExecutionTask> + Send>,
notifier: Box<dyn ExecutionTaskCompletionNotifier>
) -> Result<(), ExecutorError>
Submits an Iterator of Execution tasks and a completion notifier to the Executor for processing. The iterator provided will be consumed until either it is exhausted or the Executor is shutdown.
Errors
Returns an ExecutorError if the tasks cannot be successfully sent to the Executor, due to
the Executor being disconnected from this ExecutionTaskSubmitter.
Trait Implementations
fn pass_scheduler(
&mut self,
task_iterator: Box<dyn Iterator<Item = ExecutionTask> + Send>,
notifier: Box<dyn ExecutionTaskCompletionNotifier>
) -> Result<(), String>
fn pass_scheduler(
&mut self,
task_iterator: Box<dyn Iterator<Item = ExecutionTask> + Send>,
notifier: Box<dyn ExecutionTaskCompletionNotifier>
) -> Result<(), String>
Gives the task iterator and notifier of a sub-scheduler to the sub-scheduler handler; the sub-scheduler handler will get tasks directly from the sub-scheduler and send task execution reults back to the sub-scheduler. Read more
Auto Trait Implementations
impl !RefUnwindSafe for ExecutionTaskSubmitter
impl Send for ExecutionTaskSubmitter
impl !Sync for ExecutionTaskSubmitter
impl Unpin for ExecutionTaskSubmitter
impl !UnwindSafe for ExecutionTaskSubmitter
Blanket Implementations
Mutably borrows from an owned value. Read more
pub fn clone_boxed(&self) -> Box<dyn DefaultFeatures<'a> + 'a, Global>
pub fn clone_boxed(&self) -> Box<dyn DefaultFeatures<'a> + 'a, Global>
Clone this value, and then immediately put it into a Box
behind a trait object of this trait. Read more
pub fn self_address_mut(&mut self) -> *mut ()
pub fn self_address_mut(&mut self) -> *mut ()
Returns the address of self. Read more
Convert self to an expression for Diesel’s query builder. Read more
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
fn as_sql<'a, T>(&'a self) -> <&'a Self as AsExpression<T>>::Expression where
&'a Self: AsExpression<T>,
Convert &self to an expression for Diesel’s query builder. Read more
impl<'a, T> NonSyncFeatures<'a> for T where
T: 'a + Clone,
impl<'a, T> NonSyncFeatures<'a> for T where
T: 'a + Clone,
pub fn clone_boxed(&self) -> Box<dyn NonSyncFeatures<'a> + 'a, Global>
pub fn clone_boxed(&self) -> Box<dyn NonSyncFeatures<'a> + 'a, Global>
Clone this value, and then immediately put it into a Box
behind a trait object of this trait. Read more
pub fn self_address_mut(&mut self) -> *mut ()
pub fn self_address_mut(&mut self) -> *mut ()
Returns the address of self. Read more
impl<T> SafeBorrow<T> for T where
T: ?Sized,
impl<T> SafeBorrow<T> for T where
T: ?Sized,
pub fn borrow_replacement(ptr: &T) -> &T
pub fn borrow_replacement(ptr: &T) -> &T
Given ptr, which was obtained from a prior call to Self::borrow(),
return a value with the same nominal lifetime which is guaranteed to
survive mutations to Self. Read more
pub fn vzip(self) -> V
Attaches the provided Subscriber to this type, returning a
WithDispatch wrapper. Read more
Attaches the current default Subscriber to this type, returning a
WithDispatch wrapper. Read more