Struct EventStream 

pub struct EventStream { /* private fields */ }

Event stream for polling job events.

Implementations

impl EventStream

pub fn new(client: HttpClient, base_url: &str, job_id: &str) -> Self

Create a new event stream for a job.

pub fn with_start_seq(self, seq: i64) -> Self

Set the starting sequence number.

pub fn with_deduplicate(self, dedupe: bool) -> Self

Enable or disable deduplication.

pub fn with_max_events(self, max: i32) -> Self

Set max events per poll.

pub fn last_seq(&self) -> i64

Get the last seen sequence number.

pub async fn poll_events(&mut self) -> Result<Vec<ParsedEvent>, CoreError>

Poll for new events.

Returns events since the last sequence number.

pub async fn stream_until<F, T>( &mut self, on_event: F, timeout: Duration, poll_interval: Duration, is_terminal: T, ) -> Result<(), CoreError>

where F: FnMut(&ParsedEvent), T: FnMut() -> bool,

Stream events until a terminal condition with callback.

Arguments

• on_event - Callback for each event
• timeout - Maximum time to stream
• poll_interval - Time between polls
• is_terminal - Optional check for terminal status