 
         return ApolloStore(cache: cache)
     }
+
+    private func delay(dueTime: RxTimeInterval, closure: @escaping (Void) -> Void) {
+        Observable<Void>.empty().delay(dueTime, scheduler: MainScheduler.instance)
+            .subscribe(onCompleted: closure)
+            .disposed(by: disposeBag)
+    }
 }

import RxBlocking

class RxApolloTests: XCTestCase {

    // MARK: - Query
    


        _ = watched.connect()

        delay(dueTime: 0.1) {
            client.fetch(query: HeroNameQuery(), cachePolicy: .fetchIgnoringCacheData)
        }

        let results = try watched.take(2).timeout(5, scheduler: MainScheduler.instance).toBlocking().toArray()

