|
@@ -25,11 +25,11 @@ public class SseEmitterManager {
|
|
|
public void addEmitter(String emitterKey, SseEmitterUTF8 emitter) {
|
|
|
this.emitters.put(emitterKey, emitter);
|
|
|
emitter.onTimeout(() -> {
|
|
|
- System.out.println("(onTimeout) emitter 超时, emitterKey: " + emitterKey);
|
|
|
+ System.out.println("(sse)(onTimeout) emitter 超时, emitterKey: " + emitterKey);
|
|
|
removeEmitter(emitter);
|
|
|
});
|
|
|
emitter.onCompletion(() -> {
|
|
|
- System.out.println("(onCompletion) emitter 中断, emitterKey: " + emitterKey);
|
|
|
+ System.out.println("(sse)(onCompletion) emitter 中断, emitterKey: " + emitterKey);
|
|
|
removeEmitter(emitter);
|
|
|
});
|
|
|
}
|