|
@@ -45,7 +45,7 @@ public class SseEmitterManager {
|
|
public void removeEmitter(SseEmitterUTF8 emitter) {
|
|
public void removeEmitter(SseEmitterUTF8 emitter) {
|
|
this.emitters.values().removeIf(e -> e == emitter); // 安全移除
|
|
this.emitters.values().removeIf(e -> e == emitter); // 安全移除
|
|
try {
|
|
try {
|
|
- System.out.println("(removeEmitter) emitter 关闭: " + emitter);
|
|
|
|
|
|
+ // System.out.println("(removeEmitter) emitter 关闭: " + emitter);
|
|
emitter.complete();
|
|
emitter.complete();
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
System.err.println("Failed to forcefully close emitter: " + e.getMessage());
|
|
System.err.println("Failed to forcefully close emitter: " + e.getMessage());
|