Erstellen eines RxJS Observable von einer (vom Server gesendeten) EventSource

Ich möchte eine RxJs Observable aus einer EventSource erstellen (vom Server gesendete Ereignisse). Ich habe Folgendes versucht: import {Component, OnInit} from 'angular2/core'; import {Subject, Observable} from 'rxjs/Rx'; @Component({ ...