Struct RepeatStage 

pub struct RepeatStage {
    pub count: usize,
    pub stage_for_index: Arc<dyn Fn(usize) -> FlowStage + Send + Sync>,
}

Fields

count: usize

stage_for_index: Arc<dyn Fn(usize) -> FlowStage + Send + Sync>

Implementations

impl RepeatStage

pub fn new( count: usize, stage_for_index: impl Fn(usize) -> FlowStage + Send + Sync + 'static, ) -> Self

impl RepeatStage

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

Trait Implementations

impl Clone for RepeatStage

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RepeatStage

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

Formats the value using the given formatter.