                         self.createRecords(records: (100, Event<Int>.completed)))
                     isSubscribed.append(false)
                     users.append(testScheduler.scheduleObservable {
-                        return .deferred {
+                        return Observable.deferred {
                             isSubscribed[3] = true
                             return ob4.asObservable()
                             }.queueSubscribe(on: serializedQueue)

                        self.createRecords(records: (100, Event<Int>.completed)))
                    isSubscribed.append(false)
                    users.append(testScheduler.scheduleObservable(time: ObservableScheduleTimes(createTime: 0, subscribeTime: 200, disposeTime: 500)) {
                        return .deferred {
                            isSubscribed[2] = true
                            return ob3.asObservable()
                            }.queueSubscribe(on: serializedQueue)

                        self.createRecords(records: (300, Event<Int>.completed)))
                    isSubscribed.append(false)
                    users.append(testScheduler.scheduleObservable {
                        return Observable.deferred {
                            isSubscribed[0] = true
                            return ob1.asObservable()
                        }.queueSubscribe(on: serializedQueue)
