Package org.a2aproject.sdk.client.http

Class ServerSentEventParser

java.lang.Object

org.a2aproject.sdk.client.http.ServerSentEventParser

public class ServerSentEventParser
extends Object

Streaming parser for Server-Sent Events (SSE).

Feed lines one at a time via processLine(java.lang.String); call flush() when the stream ends. Not thread-safe — each connection should use its own instance.

Constructor Summary

Constructors

Constructor	Description
ServerSentEventParser(Consumer<ServerSentEvent> eventConsumer)
ServerSentEventParser(Consumer<ServerSentEvent> eventConsumer, @Nullable Consumer<Throwable> errorConsumer)

Method Summary

Modifier and Type	Method	Description
void	flush()	Dispatches any buffered data not yet followed by an empty line.
@Nullable String	getLastEventId()	Returns the last event ID received, or null if none.
@Nullable Long	getRetry()	Returns the reconnection interval in milliseconds from the last retry: field, or null if none.
void	processLine(@Nullable String line)	Processes a single line from the SSE stream.

Methods inherited from class java.lang.Object

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

Constructor Details

ServerSentEventParser

public ServerSentEventParser(Consumer<ServerSentEvent> eventConsumer)

ServerSentEventParser

public ServerSentEventParser(Consumer<ServerSentEvent> eventConsumer,
 @Nullable Consumer<Throwable> errorConsumer)

Method Details

processLine

public void processLine(@Nullable String line)

Processes a single line from the SSE stream. An empty line dispatches any buffered event. A null line is routed to the error consumer (or logged) without affecting the current event block.

flush

public void flush()

Dispatches any buffered data not yet followed by an empty line. Call when the stream ends.

getLastEventId

public @Nullable String getLastEventId()

Returns the last event ID received, or null if none.

getRetry

public @Nullable Long getRetry()

Returns the reconnection interval in milliseconds from the last retry: field, or null if none.