Method next

sdk/node/src/lib.rs:1148–1190

(&self)

    /// When `done` is true, the stream is exhausted.
    #[napi]
    pub async fn next(&self) -> napi::Result<NextResult> {
        if self.done.load(Ordering::Relaxed) {
            return Ok(NextResult {
                value: None,
                done: true,
            });
        }
        let rx = self.rx.clone();
        let done_flag = self.done.clone();
        let result = get_runtime()
            .spawn(async move {
                let mut guard = rx.lock().await;
                guard.recv().await
            })
            .await
            .map_err(|e| napi::Error::from_reason(format!("Task join error: {e}")))?;
        match result {
            Some(event) => {
                let is_end = matches!(event, RustAgentEvent::End { .. });
                let is_error = matches!(event, RustAgentEvent::Error { .. });
                let js_event = AgentEvent::from(event);
                if is_end || is_error {
                    done_flag.store(true, Ordering::Relaxed);
                    Ok(NextResult {
                        value: Some(js_event),
                        done: true,
                    })
                } else {
                    Ok(NextResult {
                        value: Some(js_event),
                        done: false,
                    })
                }
            }
            None => {
                done_flag.store(true, Ordering::Relaxed);
                Ok(NextResult {
                    value: None,
                    done: true,
                })
            }
        }
    }
}

// ============================================================================