Struct StreamEventSource 

pub struct StreamEventSource { /* private fields */ }

Bridges a StreamValue to the kernel EventSource contract.

Holds the stream, the run Ref that events are attributed to, and the sequencing state. Construct one with StreamEventSource::new (or StreamValue::event_source) and pull events through the EventSource implementation.

Implementations

impl StreamEventSource

pub fn new(stream: Arc<StreamValue>, run: Ref, start_seq: u64) -> Self

Creates an event source over stream, attributing emitted events to run and numbering them from start_seq.

Trait Implementations

impl EventSource for StreamEventSource

fn next(&self, cx: &mut Cx) -> Result<Option<Event>>

Pull the next event, or None when the source is exhausted.

fn close(&self, _cx: &mut Cx) -> Result<()>

Release the source’s resources; the default is a no-op.