Example of an observable using vertebrate-event-emitter.

observable.js

'use strict';

import Observable from 'an-observable-implementation';
import emitter from 'some-instance-of-vertebrate-event-emitter';

export default new Observable(observer => {
  const refs = [
    emitter.on('data', data => observer.next(data)),
    emitter.on('error', error => observer.error(error)),
    emitter.on('end', () => observer.complete())
  ];

  return () => refs.forEach(ref => emitter.off(ref));
});