Package dev.langchain4j.http.client.sse

Class DefaultServerSentEventParser

java.lang.Object

dev.langchain4j.http.client.sse.DefaultServerSentEventParser

All Implemented Interfaces:

ServerSentEventParser

public class DefaultServerSentEventParser
extends Object
implements ServerSentEventParser

Constructor Summary

Constructors

Constructor	Description
DefaultServerSentEventParser()

Method Summary

Modifier and Type	Method	Description
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 java.lang.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