window['EventSource']('/events/');
eventSource.onmessage = x => observer.next(x.data);