Package ai.acolite.agentsdk.core

Class StreamedRunResult<TContext,TAgent extends Agent<TContext,? extends AgentOutputType>>

java.lang.Object

ai.acolite.agentsdk.core.StreamedRunResult<TContext,TAgent>

All Implemented Interfaces:

AsyncIterable<RunStreamEvent>, Iterable<RunStreamEvent>

public class StreamedRunResult<TContext,TAgent extends Agent<TContext,? extends AgentOutputType>>
extends Object
implements AsyncIterable<RunStreamEvent>

StreamedRunResult

Ported from TypeScript OpenAI Agents SDK Source: result.ts

Constructor Summary

Constructors

Constructor	Description
StreamedRunResult()

Method Summary

Modifier and Type	Method	Description
Optional<AbortSignal>	_getAbortSignal()	_getAbortSignal
Optional<CompletableFuture<Void>>	_getStreamLoopPromise()	_getStreamLoopPromise
Iterator<RunStreamEvent>	iterator()
ReadableStream<RunStreamEvent>	toStream()	Get the event stream for this run.
ReadableStream<String>	toTextStream()	Get a text-only stream that emits content from message output events.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

StreamedRunResult

public StreamedRunResult()

Method Details

toStream

public ReadableStream<RunStreamEvent> toStream()

Get the event stream for this run. Events are emitted in real-time as execution progresses.

Returns:

ReadableStream that emits RunStreamEvent objects

toTextStream

public ReadableStream<String> toTextStream()

Get a text-only stream that emits content from message output events. Convenience method for applications that only care about text responses.

Returns:

ReadableStream that emits String content

_getStreamLoopPromise

public Optional<CompletableFuture<Void>> _getStreamLoopPromise()

_getStreamLoopPromise

Returns:

Optionalinvalid input: '<'CompletableFuture>

Throws:

NotImplementedException - Not yet implemented

_getAbortSignal

public Optional<AbortSignal> _getAbortSignal()

_getAbortSignal

Returns:

Optional

Throws:

NotImplementedException - Not yet implemented

iterator

public Iterator<RunStreamEvent> iterator()

Specified by:

iterator in interface AsyncIterable<TContext>

Specified by:

iterator in interface Iterable<TContext>