var test = require("test");
var Rx = require("rx.vertx");
var eb = vertx.eventBus();
var consumer = eb.localConsumer("the-address");
var observer1 = Rx.Observer.create(
  function (evt) {
    test.fail("onNext called");
  },
  function (err) {
    test.fail(err);
  },
  function () {
  }
);
var observer2 = Rx.Observer.create(
  function (evt) {
    test.fail();
  },
  function (err) {
    test.testComplete();
  },
  function () {
    test.testComplete();
  }
);
var observable = Rx.Observable.fromReadStream(consumer);
observable.subscribe(observer1);
observable.subscribe(observer2);
