             next(301, 4),
             next(350, 5),
             next(399, 6),
-            completed(600),
+            completed(500),
             ])
         
         XCTAssertEqual(underlying.subscriptions, [

            next(220, 2),
            next(230, 3),
            next(400, 6),
            completed(600),
            ])
        
        XCTAssertEqual(underlying.subscriptions, [

            next(220, true),
            next(300, false),
            next(400, true),
            ])
        
        let res = scheduler.start(1000) {
