Trait ya_runtime_sdk::RunCommandExt

pub trait RunCommandExt<R: Runtime + ?Sized> {
    type Item: 'static;
    fn as_command<'a, H, Fh>(
        self, 
        ctx: &mut Context<R>, 
        handler: H
    ) -> ProcessIdResponse<'a>
    where
        H: FnOnce(Self::Item, RunCommandContext) -> Fh + 'static,
        Fh: Future<Output = Result<(), Error>> + 'static;
}

Wraps command lifecycle in the following manner:

• manages command sequence numbers
• emits command start & stop events
• provides a RunCommandContext object for easier output event emission

Associated Types

type Item: 'static

Required methods

fn as_command<'a, H, Fh>(
    self,
    ctx: &mut Context<R>,
    handler: H
) -> ProcessIdResponse<'a> where
    H: FnOnce(Self::Item, RunCommandContext) -> Fh + 'static,
    Fh: Future<Output = Result<(), Error>> + 'static, 

Wrap self in run_command

Implementors

impl<R: ?Sized, F, Rt, Re> RunCommandExt<R> for F where
    R: Runtime,
    F: Future<Output = Result<Rt, Re>> + 'static,
    Rt: 'static,
    Re: 'static,
    Error: From<Re>, 

Implements RunCommandExt for Futures outputting Results. The output result is checked prior to emitting any command lifecycle events.

type Item = Rt

fn as_command<'a, H, Fh>(
    self,
    ctx: &mut Context<R>,
    handler: H
) -> ProcessIdResponse<'a> where
    H: FnOnce(Self::Item, RunCommandContext) -> Fh + 'static,
    Fh: Future<Output = Result<(), Error>> + 'static,