         }
         
         XCTAssertEqual(res.events, [
-            next(250, 4),
-            completed(250)
+            .next(250, 4),
+            .completed(250)
             ])
         
         XCTAssertEqual(xs.subscriptions, [

        let scheduler = TestScheduler(initialClock: 0)
        
        let xs = scheduler.createHotObservable([
            next(150, 1),
            next(210, 2),
            completed(250),
            error(260, testError)
            ])
        
        let res = scheduler.start { () -> Observable<Int> in

        let scheduler = TestScheduler(initialClock: 0)
        
        let xs = scheduler.createHotObservable([
            .next(150, 1),
            .next(160, 2),
            .next(280, 3),
            .next(250, 4),
            .next(300, 5)
            ])
        
        let res = scheduler.start { () -> Observable<Int> in
