Struct DualStreamStage 

pub struct DualStreamStage {
    pub name: String,
    pub stream_a: String,
    pub stream_b: String,
    /* private fields */
}

Transform two named streams in place (e.g. FLUX img/txt dual block).

Fields

name: String

stream_a: String

stream_b: String

Implementations

impl DualStreamStage

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

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

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

Trait Implementations

impl Clone for DualStreamStage

fn clone(&self) -> DualStreamStage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DualStreamStage

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

Formats the value using the given formatter.