javascript - RxJs で TestScheduler を使用してサブジェクトをテストする

Question

RxJs を使用して、特定の時間枠に到着するパケット数をカウントしています。私のコードは基本的に次のようになります。

var packetSubject = new Rx.Subject();
var packetsInWindow = [];

function startMonitoring() {
    var subscription = packetSubject
        .windowWithTime(1000)
        .select(function(window) {
            window.toArray().subscribe(function(elements) {
                packetsInWindow.push(elements.length);
            });
        })
        .subscribe();
}

function newPacket(packet) {
    packetSubject.onNext(packet);
}

Rx TestScheduler を使用してこのコードを単体テストする方法は? サブジェクトのテストに適した例が見つかりませんでした。