Struct ChannelSink 

pub struct ChannelSink { /* private fields */ }

A sink that forwards every RungProgress into a Tokio mpsc channel, turning the callback into an async stream the caller can .recv().await. Sends are non-blocking (try_send); if the channel is full or closed the update is dropped (progress is advisory, never load-bearing).

Implementations

impl ChannelSink

pub fn new(tx: Sender<RungProgress>) -> Self

Trait Implementations

impl ProgressSink for ChannelSink

fn on_rung(&self, update: RungProgress)

Called with a fresh RungProgress each time a rung advances.

fn on_event(&self, _event: JobEvent)

Called for job-level lifecycle events. Default: ignore.