Method init

src/main/java/com/github/websocket/Emitter.java:14–26

()

    private final CopyOnWriteArrayList<SseEmitter> emitters = new CopyOnWriteArrayList<>();

    public SseEmitter init() {
        SseEmitter emitter = new SseEmitter(60000L);
        // 连接成功需要返回数据，否则会出现待处理状态
        try {
            emitter.send(SseEmitter.event().comment("success"));
        } catch (IOException e) {
            e.printStackTrace();
        }
        emitters.add(emitter);
        emitter.onCompletion(() -> emitters.remove(emitter));
        emitter.onTimeout(() -> emitters.remove(emitter));
        return emitter;
    }

    public void sendEvent(String event) {
        emitters.forEach(emitter -> {