MessageConsumer spec without Subject

messageConsumer.spec.js

describe('MessageConsumer', function () {
  var observer;

  beforeEach(function () {
    var source = Rx.Observable.create(function (o) {
      observer = o;
    });

    var provider = new MessageProvider();  
    spyOn(provider, 'getMessage').and.returnValue(source)

    consumer = new MessageConsumer(provider);
  });

  it('gets the messages', function () {
    expect(consumer.message).toEqual(undefined);

    observer.onNext('hello there');

    expect(consumer.message).toEqual('hello there');
  });
});