Struct Channel 

pub struct Channel<T> { /* private fields */ }

A re-iterable channel: a cloneable handle around a stream factory. Each call to Channel::iter re-runs the factory, producing a brand-new stream — so iterating the channel twice issues the underlying work twice.

Implementations

impl<T> Channel<T>

pub fn of<F>(factory: F) -> Self

where F: Fn() -> BoxStream<T> + Send + Sync + 'static,

Build a channel from a stream factory. The factory is invoked once per Channel::iter call; it must be re-runnable (Fn, not FnOnce) and should clone any per-iteration inputs it captures.

pub fn iter(&self) -> BoxStream<T>

Produce a fresh stream by re-running the factory. Calling this twice runs the factory twice — the re-iterable contract.

Trait Implementations

impl<T: Clone> Clone for Channel<T>

fn clone(&self) -> Channel<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.