Struct LoadStreamStage 

pub struct LoadStreamStage {
    pub name: String,
}

Replace the active tensor flow from a named stream.

Fields

name: String

Implementations

impl LoadStreamStage

pub fn new(name: impl Into<String>) -> Self

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

Trait Implementations

impl Clone for LoadStreamStage

fn clone(&self) -> LoadStreamStage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LoadStreamStage

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

Formats the value using the given formatter.