Return disposal function on subscribe...

[zebulonj]

...to allow external initiation of termination (unsubscribe).

const source = fromEvent( ... );
const observer = {
  next: val => console.log( val )
};

const dispose = subscribe( observer )( source );
dispose();