Creating observables from DOM events (or EventEmitter)