Crear un RxJS Observable desde un EventSource (enviado por el servidor)

Me gustaría crear un RxJs Observable desde un EventSource (eventos enviados por el servidor). Intenté lo siguiente: import {Component, OnInit} from 'angular2/core'; import {Subject, Observable} from 'rxjs/Rx'; @Component({ selector: 'my-app', ...