Struct Attach 

pub struct Attach<P: Phase, Prod: Producer, Cons: Consumer> { /* private fields */ }

The typed attach handle. P is the current phase; the available methods are gated on P so malformed call sequences are compile errors rather than runtime mismatches.

Implementations

impl<Prod, Cons> Attach<Spawned, Prod, Cons>

where Prod: Producer, Cons: Consumer<Item = Prod::Item, Snap = Prod::Snap>,

pub fn builder() -> AttachConfigBuilder<Prod, Cons, ((), ())>

Public entry point — Attach::builder().

impl<Prod, Cons> Attach<Spawned, Prod, Cons>

where Prod: Producer, Cons: Consumer<Item = Prod::Item, Snap = Prod::Snap>,

pub fn subscribe( self, ) -> Result<(Attach<Subscribed, Prod, Cons>, History<Prod::Snap>), AttachError>

Spawned → Subscribed. Subscribe to the live stream FIRST (so no item between subscribe and snapshot is lost), then capture the snapshot. Returns the new phase + a History handle that must be passed to replay (drop-bomb prevents forgetting).

impl<Prod, Cons> Attach<Subscribed, Prod, Cons>

where Prod: Producer, Cons: Consumer<Item = Prod::Item, Snap = Prod::Snap>,

pub fn replay( self, history: History<Prod::Snap>, ) -> Result<Attach<Synced, Prod, Cons>, AttachError>

Subscribed → Synced. Consumes the History handle and replays the snapshot into the consumer. History is moved (not borrowed) so the type system enforces “exactly once”.

impl<Prod, Cons> Attach<Synced, Prod, Cons>

where Prod: Producer, Cons: Consumer<Item = Prod::Item, Snap = Prod::Snap>,

pub fn start_live(self) -> Attach<Live, Prod, Cons>

Synced → Live. Items queued in the live receiver since subscribe begin flowing into the consumer. Returns Attach<Live> — the only phase from which run is reachable.

impl<Prod, Cons> Attach<Live, Prod, Cons>

where Prod: Producer, Cons: Consumer<Item = Prod::Item, Snap = Prod::Snap>,

pub fn run(self) -> Cons

Drain the live receiver synchronously, forwarding each item to the consumer. Blocks until the producer drops its sender (clean closure) or the receiver errors. Returns the consumer so the caller can inspect terminal state.

pub fn poll_one(&mut self) -> bool

Non-blocking single-item drain. Returns true if an item was consumed; false if the channel is empty or closed. Useful for embedding the drain inside an existing event loop (winit, tokio task, etc.) instead of dedicating a thread.