Package com.google.genai.gaos

Class ContinuationEventStream

java.lang.Object

com.google.genai.gaos.utils.EventStream<InteractionSSEStreamEvent>

com.google.genai.gaos.ContinuationEventStream

All Implemented Interfaces:

AutoCloseable, Iterable<InteractionSSEStreamEvent>

public final class ContinuationEventStream
extends EventStream<InteractionSSEStreamEvent>

An EventStream of a streaming interactions.create() call that automatically continues across hops (HTTP requests).

Every event of every hop is yielded verbatim and in order, including each hop's own interaction.created and intermediate interaction.completed (with status requires_continuation) events. When a hop completes with requires_continuation and a token, the next hop is requested from that token. When the transport drops (or the stream ends) mid-hop after an interaction.status_update checkpoint token, and nothing was yielded since that checkpoint, the hop is resumed from it; a hop that drops before making progress is retried from its start token up to InteractionContinuation.MAX_STREAM_RECONNECTS_WITHOUT_PROGRESS times in a row. SSE error events are terminal; HTTP status errors are not retried here.

Hand-written (not generated). Per-hop state lives in a ContinuationEventStream.Hop record replaced wholesale when a hop starts, so per-hop fields cannot leak across hops; loop state (next resume token and owner, no-progress reconnect counter, pending transport error) persists on the stream.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ContinuationEventStream.HopOpener	Opens the stream of a continuation hop.

Constructor Summary

Constructors

Constructor	Description
ContinuationEventStream(EventStream<InteractionSSEStreamEvent> initial, ContinuationEventStream.HopOpener opener, String initialContinuationToken, com.google.genai.gaos.InteractionContinuation.CallDeadline deadline)	Creates a stream that continues initial across hops.

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isClosed()
Optional<InteractionSSEStreamEvent>	next()	Returns the next message.

Methods inherited from class com.google.genai.gaos.utils.EventStream

iterator, stream, toList

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

ContinuationEventStream

public ContinuationEventStream(EventStream<InteractionSSEStreamEvent> initial,
 ContinuationEventStream.HopOpener opener,
 @Nullable
 String initialContinuationToken,
 com.google.genai.gaos.InteractionContinuation.CallDeadline deadline)

Creates a stream that continues initial across hops.

Parameters:

initial - the first hop's stream (its HTTP response headers were already received)

opener - opens the stream of each further hop

initialContinuationToken - the caller's own continuation_token, if any

deadline - the whole-call deadline, checked before each hop and before each event

Method Details

next

public Optional<InteractionSSEStreamEvent> next()
                                         throws IOException

Description copied from class: EventStream

Returns the next message. If another message does not exist returns Optional.empty().

Overrides:

next in class EventStream<InteractionSSEStreamEvent>

Returns:

the next message or Optional.empty() if no more messages

Throws:

IOException - when parsing the next message.

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Overrides:

close in class EventStream<InteractionSSEStreamEvent>

Throws:

IOException

isClosed

public boolean isClosed()

Overrides:

isClosed in class EventStream<InteractionSSEStreamEvent>