yvjia/src/main/java/com/backendsys/modules/sdk/comfyui/service/ComfyUISocketService.java

package com.backendsys.modules.sdk.comfyui.service;

import reactor.core.publisher.Mono;

import java.util.Map;

public interface ComfyUISocketService {

    // [ComfyUI] 创建 WebSocket 监听连接
    Mono<Void> connect(String clientId, Integer port);

    // [ComfyUI] 创建 WebSocket 监听连接 (转发到 SSE)
    Mono<Void> connectToSse(String clientId, Integer port);
    Mono<Void> connectToSse(String clientId, Integer port, Map<String, Object> params);

    // [ComfyUI] 断开 WebSocket 监听连接
    Mono<Void> disconnect(String clientId);

}