RxJS Marble Testing

create-observable.ts

const testScheduler = new TestScheduler();
const hotObservable = testScheduler.createHotObservable(hotMarbleString);
const coldObservable = testScheduler.createColdObservable(coldMarbleString);

observable-with-data.ts

testScheduler.createHotObservable('-a|',{a: {firstName: 'Dave', lastName: 'Bush'}});

simple-observable.ts

'a|'

spy-on.ts

testScheduler = new TestScheduler(null);
spyOn(Observable, 'timer').and.returnValue(testScheduler.createHotObservable('---a|'));