llm4s-docs
API
Generated with
llm4s-docs/org.llm4s/org.llm4s.javaapi/StreamEvents

StreamEvents

org.llm4s.javaapi.StreamEvents
object StreamEvents

Reads an AgentStreamListener's events from Java without scala.Option.

agent.stream(threadId, "Explain monads", event ->
   StreamEvents.decode(AgentEvents.TextDelta(), event).ifPresent(d -> System.out.print(d.text())));

A StreamEvent.LiveGap - live events dropped because the listener fell behind - is matched with instanceof StreamEvent.LiveGap, and its count read with dropped().

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def decode[A](eventType: EventType[A], event: StreamEvent): Optional[A]

The payload of event when it is an event of eventType - one of AgentEvents' (TextDelta(), ToolExecuted(), ...) or your own - and empty otherwise: another event, version or an undecodable payload.

The payload of event when it is an event of eventType - one of AgentEvents' (TextDelta(), ToolExecuted(), ...) or your own - and empty otherwise: another event, version or an undecodable payload.

Attributes

Generated with