Struct CustomStage 

pub struct CustomStage {
    pub name: Option<String>,
    /* private fields */
}

User-defined stage — tier-2 escape hatch for novel subgraphs.

Fields

name: Option<String>

Implementations

impl CustomStage

pub fn new<F>(f: F) -> Self

where F: Fn(&mut Emit<'_>, Option<FlowValue>) -> Result<Option<FlowValue>> + Send + Sync + 'static,

pub fn named<F>(name: impl Into<String>, f: F) -> Self

where F: Fn(&mut Emit<'_>, Option<FlowValue>) -> Result<Option<FlowValue>> + Send + Sync + 'static,

pub fn emit( &self, ctx: &mut FlowCtx<'_>, input: Option<FlowValue>, ) -> Result<Option<FlowValue>>

Trait Implementations

impl Clone for CustomStage

fn clone(&self) -> CustomStage

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for CustomStage

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.