Struct SourceChain 

pub struct SourceChain<S, T>(pub S, pub T);

Fuse a transform onto a source, yielding the transform’s output: the static analog of a source ! transform bin. A const-arity runner slot that takes one source can then carry a whole linear branch, which is how a fan-in graph gets per-input chains (run_sources_fanin_sink with a SourceChain in each source slot). A frame the transform drops (Ok(None)) is pulled past (the fused source polls the inner source again), so downstream sees only surviving frames; end of stream is the inner source’s.

Tuple Fields

0: S

1: T

Trait Implementations

impl<S: Debug, T: Debug> Debug for SourceChain<S, T>

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

Formats the value using the given formatter.

impl<S: Recover, T: Recover> Recover for SourceChain<S, T>

async fn recover(&mut self) -> Result<(), G2gError>

Re-initialize after a fault. The default is a no-op (a stateless stage).

impl<S: StaticSource, T: StaticTransform> StaticSource for SourceChain<S, T>

async fn next(&mut self) -> Result<Option<Frame>, G2gError>

Produce the next frame, or Ok(None) at end of stream.