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