Trait teo_runtime::pipeline::item::transform::TransformArgument

pub trait TransformArgument<A, O: Into<Object>, R: Into<TransformResult<O>>>: Send + Sync + 'static {
    // Required method
    fn call(&self, args: Arguments, ctx: Ctx) -> BoxFuture<'static, R>;
}

Required Methods

fn call(&self, args: Arguments, ctx: Ctx) -> BoxFuture<'static, R>

Implementors

impl<A0, A1, A2, A3, O, F, R, Fut> TransformArgument<(A0, A1, A2, A3), O, R> for F

where A0: TryFrom<Object, Error = Error> + Send + Sync, A1: ExtractFromPipelineCtx + Send + Sync, A2: ExtractFromPipelineCtx + Send + Sync, A3: ExtractFromPipelineCtx + Send + Sync, F: Fn(A0, A1, A2, A3) -> Fut + Sync + Send + 'static, O: Into<Object> + Sync + Send, R: Into<TransformResult<O>> + Send + Sync, Fut: Future<Output = R> + Send + 'static,

impl<A0, A1, A2, O, F, R, Fut> TransformArgument<(A0, A1, A2), O, R> for F

where A0: TryFrom<Object, Error = Error> + Send + Sync, A1: ExtractFromPipelineCtx + Send + Sync, A2: ExtractFromPipelineCtx + Send + Sync, F: Fn(A0, A1, A2) -> Fut + Sync + Send + 'static, O: Into<Object> + Sync + Send, R: Into<TransformResult<O>> + Send + Sync, Fut: Future<Output = R> + Send + 'static,

impl<A0, A1, O, F, R, Fut> TransformArgument<(A0, A1), O, R> for F

where A0: TryFrom<Object, Error = Error> + Send + Sync, A1: ExtractFromPipelineCtx + Send + Sync, F: Fn(A0, A1) -> Fut + Sync + Send + 'static, O: Into<Object> + Sync + Send, R: Into<TransformResult<O>> + Send + Sync, Fut: Future<Output = R> + Send + 'static,

impl<A0, O, F, R, Fut> TransformArgument<(A0,), O, R> for F

where A0: TryFrom<Object, Error = Error> + Send + Sync, F: Fn(A0) -> Fut + Sync + Send + Clone + 'static, O: Into<Object> + Sync + Send, R: Into<TransformResult<O>> + Send + Sync, Fut: Future<Output = R> + Send + 'static,