Struct Source

pub struct Source<C, O> { /* private fields */ }

A channel source: external code can send values in, and this source will drive a workflow for each received item until the channel closes.

Implementations

impl<C: Context, O> Source<C, O>

pub fn new(rx: Receiver<O>) -> Self

Wrap an existing receiver into a Source

impl<C, O> Source<C, O>

where C: Context, O: Send + Sync,

pub async fn run<W>( &self, wf: &W, ctx: &WorkflowCtx<C>, ) -> Result<(), FloxideError>

where W: Workflow<C, Input = O>,

Drive the provided workflow by pulling items from the channel and invoking wf.run(ctx, item) for each until the channel closes.

Trait Implementations

impl<C: Clone, O: Clone> Clone for Source<C, O>

fn clone(&self) -> Source<C, O>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<C: Debug, O: Debug> Debug for Source<C, O>

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

Formats the value using the given formatter.