Package com.google.genai.gaos.utils

Class BlockingParser<T>

java.lang.Object

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

public final class BlockingParser<T>
extends Object

Blocking parser that reads from a Reader and delegates to a StreamingParser.

Constructor Summary

Constructors

Constructor	Description
BlockingParser(Reader reader, StreamingParser<T> parser)

Method Summary

Modifier and Type	Method	Description
void	close()	Close the underlying reader
static BlockingParser<String>	forJsonLines(Reader reader)	Create a blocking parser for JSON Lines format
static BlockingParser<EventStreamMessage>	forSSE(Reader reader)	Create a blocking parser for SSE format
boolean	hasNext()	Check if there are more results available (either buffered or from reader)
Optional<T>	next()	Read the next parsed result from the Reader.

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingParser

public BlockingParser(Reader reader,
 StreamingParser<T> parser)

Method Details

next

public Optional<T> next()
                 throws IOException

Read the next parsed result from the Reader.

Returns:

next complete parsed result, or empty if no more data

Throws:

IOException - if reading fails

hasNext

public boolean hasNext()
                throws IOException

Check if there are more results available (either buffered or from reader)

Throws:

IOException

close

public void close()
           throws IOException

Close the underlying reader

Throws:

IOException

forJsonLines

public static BlockingParser<String> forJsonLines(Reader reader)

Create a blocking parser for JSON Lines format

forSSE

public static BlockingParser<EventStreamMessage> forSSE(Reader reader)

Create a blocking parser for SSE format