Trait StreamResolver

pub trait StreamResolver<TCtx, TMarker> {
    // Required methods
    fn exec(&self, ctx: TCtx, input: Value) -> Result<LayerResult, ExecError>;
    fn typedef(defs: &mut TypeMap) -> ProcedureDataType;
}

Required Methods

fn exec(&self, ctx: TCtx, input: Value) -> Result<LayerResult, ExecError>

fn typedef(defs: &mut TypeMap) -> ProcedureDataType

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

impl<TFunc, TCtx, TArg, TResult, TStream> StreamResolver<TCtx, DoubleArgStreamMarker<TArg, TResult, TStream>> for TFunc

where TArg: DeserializeOwned + Type, TFunc: Fn(TCtx, TArg) -> TStream, TStream: Stream<Item = TResult> + Send + Sync + 'static, TResult: Serialize + Type,