Я использую SSE в своем проекте с источником события
init(channel: string) {
if (this.eventSource) { return; }
this.eventSource = new EventSource(`${environment.SSE_URL}?channel=${channel}`);
this.eventSource.onmessage = (e) => {console.log('Connected');};
}
, затем в другом месте я подписываюсь на канал
protected callListener(cb: (d) => void): (e) => void {
const callee = ({data}): void => {
const d = JSON.parse(data);
cb(d.message);
};
return callee;
}
private addEventToEventSrc(event: string, callback: any, owner: string): void {
console.log(`Subscribed to ⇢ ${event} (owned by: ${owner})`);
const cb = this.callListener(callback);
this.eventSource.addEventListener(event, cb);
if (!this.callbacks.get(`${event}_${owner}`)) {
this.callbacks.set(`${event}_${owner}`, cb);
}
}
subscribe(event: string, callback: any, owner?: string): void {
if (!this.eventSource) { return; }
if (!owner) { owner = 'default'; }
if (!event) { event = 'message'; }
this.addEventToEventSrc(event, callback, owner);
}
проблема в том, что когда я открываю EventSource, любойдругой запрос к серверу или любому другому серверу будет отложен бесконечно.Если я попадаю прямо на сервер, он отвечает, но передняя часть остается на ожидании навсегда для каждого вызова API.