pub struct RpcResult<Output> { /* private fields */ }Expand description
Carries a typed RPC output and optional Step movements.
Self::then may be called repeatedly to schedule multiple active Steps after the RPC commits.
Implementations§
Source§impl<Output: Value> RpcResult<Output>
impl<Output: Value> RpcResult<Output>
Sourcepub fn then(self, movement: StepMovement) -> Self
pub fn then(self, movement: StepMovement) -> Self
Appends one Step movement executed after the RPC succeeds.
Sourcepub fn cancel_step<SelectedStep>(self, step: &SelectedStep) -> Selfwhere
SelectedStep: Step,
pub fn cancel_step<SelectedStep>(self, step: &SelectedStep) -> Selfwhere
SelectedStep: Step,
Selects every queued or active execution of one registered Step type.
Dex resolves cancellation after RPC persistence commits and before next Steps are queued. Finished, already-canceled, and absent executions are no-ops. RPCs cannot select siblings.
Sourcepub fn next_steps(&self) -> &[StepMovement]
pub fn next_steps(&self) -> &[StepMovement]
Returns the scheduled Step movements in insertion order.
Auto Trait Implementations§
impl<Output> !RefUnwindSafe for RpcResult<Output>
impl<Output> !UnwindSafe for RpcResult<Output>
impl<Output> Forget for RpcResult<Output>
impl<Output> Freeze for RpcResult<Output>where
Output: Freeze,
impl<Output> Send for RpcResult<Output>where
Output: Send,
impl<Output> Sync for RpcResult<Output>where
Output: Sync,
impl<Output> Unpin for RpcResult<Output>where
Output: Unpin,
impl<Output> UnsafeUnpin for RpcResult<Output>where
Output: UnsafeUnpin,
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> IntoRequest<T> for T
impl<T> IntoRequest<T> for T
Source§fn into_request(self) -> Request<T>
fn into_request(self) -> Request<T>
Wrap the input message
T in a tonic::Request