i have this problem with EventSourcePolyfill , when i create new notification it doesn’t receive any thing but after some number of notifications it receive the previous notifications but also it get truncated
import { EventSourcePolyfill } from 'event-source-polyfill';
@Injectable({
providedIn: 'root'
})
getStream(): Observable<any> {
return new Observable((observer) => {
this.eventSource = new EventSourcePolyfill(this.streamUrl, {
headers: {
'Authorization': 'Bearer ' + this.authToken,
'organization-id': this.securityDTO.OrganizationId,
},
});
this.eventSource.onmessage = (event) => {
console.log(event);
observer.next(event.data);
};
this.eventSource.onerror = (error) => {
this.eventSource?.close();
this.reconnect(observer);
};
private reconnect(observer: any): void {
this.getStream().subscribe(observer);
}
and this is how i call it
this.streamService.getStream().subscribe((data: any) => {
const notification = JSON.parse(data);
console.log(data);
});