Package dev.tachyonmcp.core.transport.netty.sse

Class SseManager

java.lang.Object

dev.tachyonmcp.core.transport.netty.sse.SseManager

public class SseManager
extends Object

Manages SSE stream lifecycle for GET requests: opens stateful or stateless streams via NettySseConnection, writes opening frames and priming events, and replays missed events on reconnection.

Constructor Summary

Constructors

Constructor	Description
SseManager(ServerEngine server)

Method Summary

Modifier and Type	Method	Description
void	openStatelessStream(io.netty.channel.ChannelHandlerContext ctx, @Nullable String origin)
void	openStream(io.netty.channel.ChannelHandlerContext ctx, Session session, @Nullable String lastEventId, @Nullable String origin)

Methods inherited from class java.lang.Object

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

Constructor Details

SseManager

public SseManager(ServerEngine server)

Method Details

openStream

public void openStream(io.netty.channel.ChannelHandlerContext ctx,
 Session session,
 @Nullable String lastEventId,
 @Nullable String origin)

openStatelessStream

public void openStatelessStream(io.netty.channel.ChannelHandlerContext ctx,
 @Nullable String origin)