rx-collectionassert

A port of assertEqual from the RxJS docs to work with Node's assert lib.

(I got tired of copy-and-pasting this between projects.)

Usage

This works with any testing lib in Node; example below using tape.

var test = require('tape');
var Rx = require('rx'),
    ReactiveTest = Rx.ReactiveTest;
 
var collectionAssert = require('rx-collectionassert');
 
test('An RxJS test', function(assert) {
    var scheduler = new Rx.TestScheduler();
 
    var source = scheduler.createHotObservable(
        ReactiveTest.onNext(250, 'foo'),
        ReactiveTest.onNext(260, 'bar'),
        ReactiveTest.onCompleted(270));
 
    var results = scheduler.startScheduler(function() {
        return source.map(x => x);
    }, {created: 100, subscribed: 200, disposed: 500});
 
    collectionAssert.assertEqual(results.messages, [
        ReactiveTest.onNext(250, 'foo'),
        ReactiveTest.onNext(260, 'bar'),
        ReactiveTest.onCompleted(270),
    ]);
 
    assert.end();
});