pub struct TracedRunnable<R> { /* private fields */ }Implementations§
Source§impl<R> TracedRunnable<R>
impl<R> TracedRunnable<R>
pub fn new( inner: R, manager: CallbackManager, parent: RunContext, run_type: RunType, name: String, ) -> Self
Trait Implementations§
Source§impl<Input, Output, R> Runnable<Input, Output> for TracedRunnable<R>where
Input: Send + Sync + ToTraceInput + Clone + 'static,
Output: Send + Sync + ToTraceOutput + 'static,
R: Runnable<Input, Output> + Send + Sync,
impl<Input, Output, R> Runnable<Input, Output> for TracedRunnable<R>where
Input: Send + Sync + ToTraceInput + Clone + 'static,
Output: Send + Sync + ToTraceOutput + 'static,
R: Runnable<Input, Output> + Send + Sync,
fn invoke<'life0, 'async_trait>(
&'life0 self,
input: Input,
) -> Pin<Box<dyn Future<Output = Result<Output, WesichainError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn stream( &self, input: Input, ) -> BoxStream<'_, Result<StreamEvent, WesichainError>>
fn batch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<Input>,
) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn abatch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<Input>,
) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn to_serializable(&self) -> Option<SerializableRunnable>
Auto Trait Implementations§
impl<R> Freeze for TracedRunnable<R>where
R: Freeze,
impl<R> !RefUnwindSafe for TracedRunnable<R>
impl<R> Send for TracedRunnable<R>where
R: Send,
impl<R> Sync for TracedRunnable<R>where
R: Sync,
impl<R> Unpin for TracedRunnable<R>where
R: Unpin,
impl<R> UnsafeUnpin for TracedRunnable<R>where
R: UnsafeUnpin,
impl<R> !UnwindSafe for TracedRunnable<R>
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