                         self.createRecords(records: (250, Event<Int>.error(SomeError.error))))
                     isSubscribed.append(false)
                     users.append(testScheduler.scheduleObservable {
-                        return .deferred {
+                        return Observable.deferred {
                             isSubscribed[1] = true
                             return ob2.asObservable()
                             }.queueSubscribe(on: serializedQueue)

                        self.createRecords(records: (100, Event<Int>.completed)))
                    isSubscribed.append(false)
                    users.append(testScheduler.scheduleObservable {
                        return .deferred {
                            isSubscribed[3] = true
                            return ob4.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)
