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

            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)

        ])
    }


    func testFlatMapFirst_Complete_InnerNotComplete() {
        let scheduler = TestScheduler(initialClock: 0)

        let xs = scheduler.createHotObservable([
            next(5, scheduler.createColdObservable([
                error(1, testError)
