eventsource-polyfill

import 'eventsource-polyfill'; // Ensure polyfill is loaded function setupEventSource() { if (typeof window === 'undefined' || typeof EventSource === 'undefined') { console.warn('EventSource is not available in this environment or not polyfilled.'); return; } // Replace with your actual SSE endpoint const eventSourceUrl = 'https://example.com/stream'; // Or a mock API if running locally console.log(`Attempting to connect to EventSource at ${eventSourceUrl}`); const es = new EventSource(eventSourceUrl); es.onopen = () => { console.log('EventSource connection opened.'); }; es.onmessage = (event) => { console.log('Received message:', event.data); // You can parse JSON if your events are JSON strings try { const data = JSON.parse(event.data); console.log('Parsed JSON data:', data); } catch (e) { // Not JSON } }; es.addEventListener('customEvent', (event: MessageEvent) => { console.log('Received custom event "customEvent":', event.data); }); es.onerror = (error) => { console.error('EventSource error:', error); // Attempt to reconnect after a delay, or close if critical es.close(); console.log('EventSource closed due to error. Reconnecting in 5 seconds...'); setTimeout(setupEventSource, 5000); }; // Close the connection after some time or based on user action setTimeout(() => { es.close(); console.log('EventSource connection closed after 30 seconds.'); }, 30000); } setupEventSource();