Package com.google.genai.gaos.utils

Class StreamingParser<T>

java.lang.Object

com.google.genai.gaos.utils.StreamingParser<T>

public final class StreamingParser<T>
extends Object

Generic streaming parser that handles byte buffer management and delegates format-specific logic to a StreamContentProcessor.

Method Summary

Modifier and Type	Method	Description
Optional<T>	add(ByteBuffer inputBuffer)	Add ByteBuffer data to the parser buffer and extract any complete items.
Optional<T>	finish()	Extract any remaining partial content when stream ends.
static StreamingParser<String>	forJsonLines()	Create a streaming parser for JSON Lines format
static StreamingParser<EventStreamMessage>	forSSE()	Create a streaming parser for SSE format
boolean	hasBufferedData()	Check if parser has any buffered data
static boolean	matchesPattern(byte[] data, int pos, int limit, byte... pattern)	Check if a byte pattern matches at a specific position
Optional<T>	next()	Check if there are additional complete items in the buffer.

Methods inherited from class java.lang.Object

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

Method Details

add

public Optional<T> add(ByteBuffer inputBuffer)

Add ByteBuffer data to the parser buffer and extract any complete items.

Parameters:

inputBuffer - byte data to add (will not be modified)

Returns:

next complete parsed result if one becomes available

finish

public Optional<T> finish()

Extract any remaining partial content when stream ends.

Returns:

final parsed result if there was incomplete data in the buffer

next

public Optional<T> next()

Check if there are additional complete items in the buffer.

Returns:

next complete parsed result from buffer if available

hasBufferedData

public boolean hasBufferedData()

Check if parser has any buffered data

matchesPattern

public static boolean matchesPattern(byte[] data,
 int pos,
 int limit,
 byte... pattern)

Check if a byte pattern matches at a specific position

forJsonLines

public static StreamingParser<String> forJsonLines()

Create a streaming parser for JSON Lines format

forSSE

public static StreamingParser<EventStreamMessage> forSSE()

Create a streaming parser for SSE format