Package io.github.easy4j.opencode.api.sse

Class SseQueueSubscription

java.lang.Object

io.github.easy4j.opencode.api.sse.SseQueueSubscription

All Implemented Interfaces:

AutoCloseable

public final class SseQueueSubscription
extends Object
implements AutoCloseable

同时持有事件队列和取消句柄的 SSE 队列订阅。

Since:

1.0.0

Author:

Loong Wan

Constructor Summary

Constructors

Constructor	Description
SseQueueSubscription(BlockingQueue<SseEvent> queue, SseSubscription subscription)	创建 sse queue subscription 实例，并按传入依赖确定资源所有权。

Method Summary

Modifier and Type	Method	Description
void	close()	释放当前对象持有的连接、订阅或执行资源；重复调用是安全的。
BlockingQueue<SseEvent>	getQueue()	通过 OpenCode Server HTTP API 获取SSE 事件队列。
SseSubscription	getSubscription()	通过 OpenCode Server HTTP API 获取SSE 订阅句柄。

Methods inherited from class java.lang.Object

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

Constructor Details

SseQueueSubscription

public SseQueueSubscription(BlockingQueue<SseEvent> queue,
 SseSubscription subscription)

创建 sse queue subscription 实例，并按传入依赖确定资源所有权。

Parameters:

queue - 由调用方消费的有界 SSE 事件队列

subscription - 控制底层 SSE 连接生命周期的订阅句柄

Method Details

getQueue

public BlockingQueue<SseEvent> getQueue()

通过 OpenCode Server HTTP API 获取SSE 事件队列。

Returns:

OpenCode SDK 返回的SSE 事件队列对象

getSubscription

public SseSubscription getSubscription()

通过 OpenCode Server HTTP API 获取SSE 订阅句柄。

Returns:

用于取消连接并释放资源的订阅句柄

close

public void close()

释放当前对象持有的连接、订阅或执行资源；重复调用是安全的。

Specified by:

close in interface AutoCloseable