MessageConsumer spec with Subject

messageConsumer.spec.js

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

  beforeEach(function () {
    subject = new Rx.Subject();

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

    consumer = new MessageConsumer(provider);
  });

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

    subject.onNext('hello there');

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