小编lem*_*m1x的帖子

我正在使用 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 对这段代码进行单元测试？我找不到任何合适的示例来测试主题。