Package dev.langchain4j.mcp.client.transport.http

Class SseEventListener

java.lang.Object

okhttp3.sse.EventSourceListener

dev.langchain4j.mcp.client.transport.http.SseEventListener

public class SseEventListener
extends okhttp3.sse.EventSourceListener

Constructor Summary

Constructors

Constructor	Description
SseEventListener(McpOperationHandler messageHandler, boolean logEvents, CompletableFuture initializationFinished, Runnable onFailure)

Method Summary

Modifier and Type	Method	Description
void	onClosed(okhttp3.sse.EventSource eventSource)
void	onEvent(okhttp3.sse.EventSource eventSource, String id, String type, String data)
void	onFailure(okhttp3.sse.EventSource eventSource, Throwable t, okhttp3.Response response)
void	onOpen(okhttp3.sse.EventSource eventSource, okhttp3.Response response)

Methods inherited from class java.lang.Object

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

Constructor Details

SseEventListener

public SseEventListener(McpOperationHandler messageHandler,
 boolean logEvents,
 CompletableFuture initializationFinished,
 Runnable onFailure)

Method Details

onClosed

public void onClosed(okhttp3.sse.EventSource eventSource)

Overrides:

onClosed in class okhttp3.sse.EventSourceListener

onEvent

public void onEvent(okhttp3.sse.EventSource eventSource,
 String id,
 String type,
 String data)

Overrides:

onEvent in class okhttp3.sse.EventSourceListener

onFailure

public void onFailure(okhttp3.sse.EventSource eventSource,
 Throwable t,
 okhttp3.Response response)

Overrides:

onFailure in class okhttp3.sse.EventSourceListener

onOpen

public void onOpen(okhttp3.sse.EventSource eventSource,
 okhttp3.Response response)

Overrides:

onOpen in class okhttp3.sse.EventSourceListener