Class DefaultServerSentEventParser

java.lang.Object

dev.langchain4j.http.client.sse.DefaultServerSentEventParser

All Implemented Interfaces:

ServerSentEventParser

public class DefaultServerSentEventParser
extends Object
implements ServerSentEventParser

Nested Class Summary

Nested classes/interfaces inherited from interface ServerSentEventParser

ServerSentEventParser.Incremental

Constructor Summary

Constructors

Constructor	Description
DefaultServerSentEventParser()

Method Summary

Modifier and Type	Method	Description
ServerSentEventParser.Incremental	incremental()	Returns a fresh ServerSentEventParser.Incremental parser instance backed by the same parsing logic as ServerSentEventParser.parse(InputStream, ServerSentEventListener), but driven by byte chunks instead of a blocking InputStream.
void	parse(InputStream httpResponseBody, ServerSentEventListener listener)	Parses an input stream containing server-sent events and notifies the listener of parsed events.

Methods inherited from class Object

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

Constructor Details

DefaultServerSentEventParser

public DefaultServerSentEventParser()

Method Details

parse

public void parse(InputStream httpResponseBody,
 ServerSentEventListener listener)

Description copied from interface: ServerSentEventParser

Parses an input stream containing server-sent events and notifies the listener of parsed events. This method blocks until the input stream is exhausted or an error occurs.

For each complete event found in the stream, ServerSentEventListener.onEvent(ServerSentEvent) is called. If any parsing or processing error occurs, ServerSentEventListener.onError(Throwable) is called and parsing may terminate.

Specified by:

parse in interface ServerSentEventParser

Parameters:

httpResponseBody - the input stream containing SSE data to parse

listener - the listener to receive parsed events or error notifications

incremental

public ServerSentEventParser.Incremental incremental()

Description copied from interface: ServerSentEventParser

Returns a fresh ServerSentEventParser.Incremental parser instance backed by the same parsing logic as ServerSentEventParser.parse(InputStream, ServerSentEventListener), but driven by byte chunks instead of a blocking InputStream. Used by the publisher-based HTTP client API to avoid pinning a thread per active stream.

A parser opts into the publisher path by overriding this method. One that has not opted in throws AsyncNotSupportedException, the same "this component is not asynchronous" marker the rest of the non-blocking API reports through its return type - this method returns a plain value, so it has nowhere to carry a failure and must throw. Existing parsers that only support ServerSentEventParser.parse(InputStream, ServerSentEventListener) continue to work unchanged.

Specified by:

incremental in interface ServerSentEventParser