Struct StreamEvent 

pub struct StreamEvent {
    pub timestamp_ms: u64,
    pub kind: StreamEventKind,
}

A streaming event from an agent

Fields

timestamp_ms: u64

Timestamp in milliseconds since session start

kind: StreamEventKind

The event kind

Implementations

impl StreamEvent

pub fn new(kind: StreamEventKind) -> Self

Create a new event with the given kind

The timestamp will be set to 0 and should be updated by the store when the event is added.

pub fn with_timestamp(kind: StreamEventKind, timestamp_ms: u64) -> Self

Create a new event with an explicit timestamp

pub fn text_delta(text: impl Into<String>) -> Self

Create a text delta event

pub fn tool_start(name: &str, id: &str, input: &str) -> Self

Create a tool start event

pub fn tool_result(name: &str, id: &str, success: bool) -> Self

Create a tool result event

pub fn complete(success: bool) -> Self

Create a completion event

pub fn error(message: impl Into<String>) -> Self

Create an error event

pub fn session_assigned(session_id: impl Into<String>) -> Self

Create a session assigned event

pub fn is_terminal(&self) -> bool

Check if this event indicates completion (success or failure)

pub fn is_success(&self) -> bool

Check if this event indicates successful completion

pub fn text(&self) -> Option<&str>

Get the text content if this is a text delta event

pub fn session_id(&self) -> Option<&str>

Get the session ID if this is a session assigned event

Trait Implementations

impl Clone for StreamEvent

fn clone(&self) -> StreamEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for StreamEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamEvent

fn eq(&self, other: &StreamEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamEvent

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StreamEvent