             next(930, 401),
             next(940, 402),
             ])
-        
+
         XCTAssertEqual(xs.subscriptions, [
             Subscription(200, 1000)
             ])
-        
+
         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)
             ])
     }
-    
+
     func testFlatMapFirst_Complete_OuterNotComplete() {
         let scheduler = TestScheduler(initialClock: 0)
-        
+
         let xs = scheduler.createHotObservable([
             next(5, scheduler.createColdObservable([
                 error(1, testError)

                completed(100)
                ])),
            ])
        
        let res = scheduler.start {
            xs.flatMapFirst { $0 }
        }
        
        XCTAssertEqual(res.messages, [
            next(310, 102),
            next(390, 103),

        XCTAssertEqual(xs.recordedEvents[3].value.subscriptions, [])

        XCTAssertEqual(xs.recordedEvents[4].value.subscriptions, [])

        XCTAssertEqual(xs.recordedEvents[5].value.subscriptions, [])

        XCTAssertEqual(xs.recordedEvents[6].value.subscriptions, [
