pub struct TaskWait<'a, Input, Output> { /* private fields */ }Expand description
Awaitable typed cross-task result wait.
Created by TaskContext::await_task. Awaiting polls the target task until it reaches a
terminal state, decodes its typed output, and checkpoints that value in the parent workflow.
Implementations§
Trait Implementations§
Source§impl<'a, Input, Output> IntoFuture for TaskWait<'a, Input, Output>where
Input: Serialize + DeserializeOwned + Send + 'static,
Output: Serialize + DeserializeOwned + Send + 'static,
impl<'a, Input, Output> IntoFuture for TaskWait<'a, Input, Output>where
Input: Serialize + DeserializeOwned + Send + 'static,
Output: Serialize + DeserializeOwned + Send + 'static,
Source§type IntoFuture = Pin<Box<dyn Future<Output = <TaskWait<'a, Input, Output> as IntoFuture>::Output> + Send + 'a>>
type IntoFuture = Pin<Box<dyn Future<Output = <TaskWait<'a, Input, Output> as IntoFuture>::Output> + Send + 'a>>
Which kind of future are we turning this into?
Source§fn into_future(self) -> Self::IntoFuture
fn into_future(self) -> Self::IntoFuture
Creates a future from a value. Read more
Auto Trait Implementations§
impl<'a, Input, Output> !RefUnwindSafe for TaskWait<'a, Input, Output>
impl<'a, Input, Output> !UnwindSafe for TaskWait<'a, Input, Output>
impl<'a, Input, Output> Freeze for TaskWait<'a, Input, Output>
impl<'a, Input, Output> Send for TaskWait<'a, Input, Output>
impl<'a, Input, Output> Sync for TaskWait<'a, Input, Output>
impl<'a, Input, Output> Unpin for TaskWait<'a, Input, Output>
impl<'a, Input, Output> UnsafeUnpin for TaskWait<'a, Input, Output>
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> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§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 moreSource§impl<T> WithSubscriber for T
impl<T> WithSubscriber for T
Source§fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> ⓘ
Source§fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
fn with_current_subscriber(self) -> WithDispatch<Self> ⓘ
Layout§
Note: Most layout information is completely unstable and may even differ between compilations. The only exception is types with certain repr(...) attributes. Please see the Rust Reference's “Type Layout” chapter for details on type layout guarantees.
Size: 88 bytes