79785233

Date: 2025-10-08 08:33:50
Score: 0.5
Natty:
Report link

Convert comment to the answer. @adam-arold said it works

@EventListener 
public void onContextClosed(ContextClosedEvent event) {
    closeAllEmitters(); 
}

private void closeAllEmitters() {     
    List<SseEmitter> allEmitters = emitters.values().stream()             
        .flatMap(List::stream)             
        .collect(Collectors.toList());     
    for (SseEmitter emitter : allEmitters) {         
        try {             
            emitter.complete();         
        } catch (Exception e) {             
            log.error("Error during emitter completing");         
        }     
    }
    emitters.clear(); 
}
Reasons:
  • Long answer (-0.5):
  • Has code block (-0.5):
  • User mentioned (1): @adam-arold
  • Low reputation (0.5):
Posted by: Max