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

        }
        
        XCTAssertEqual(res.events, [
            error(210, testError)
            ])
        
        XCTAssertEqual(xs.subscriptions, [

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