         XCTAssertEqual(xs.recordedEvents[3].value.subscriptions, [])
 
         XCTAssertEqual(xs.recordedEvents[4].value.subscriptions, [])
-        
+
         XCTAssertEqual(xs.recordedEvents[5].value.subscriptions, [])
 
         XCTAssertEqual(xs.recordedEvents[6].value.subscriptions, [

            next(940, 402),
            completed(950),
            ])
        
        XCTAssertEqual(xs.subscriptions, [
            Subscription(200, 900)
            ])
        
        XCTAssertEqual(xs.recordedEvents[2].value.subscriptions, [
            Subscription(300, 760)
            ])
        
        XCTAssertEqual(xs.recordedEvents[3].value.subscriptions, [])
        
        XCTAssertEqual(xs.recordedEvents[4].value.subscriptions, [])
        
        XCTAssertEqual(xs.recordedEvents[5].value.subscriptions, [])
        
        XCTAssertEqual(xs.recordedEvents[6].value.subscriptions, [
            Subscription(850, 950)
            ])
    }


}

// MARK: flatMap

            next(940, 402),
            completed(950)
        ])

        XCTAssertEqual(xs.subscriptions, [
            Subscription(200, 900)
        ])
