 
         _ = watched.connect()
 
-        client.fetch(query: HeroNameQuery(), cachePolicy: .fetchIgnoringCacheData)
+        delay(dueTime: 0.1) {
+            client.fetch(query: HeroNameQuery(), cachePolicy: .fetchIgnoringCacheData)
+        }
 
         let results = try watched.take(2).timeout(5, scheduler: MainScheduler.instance).toBlocking().toArray()
 


        return ApolloStore(cache: cache)
    }
}

import RxBlocking

class RxApolloTests: XCTestCase {

    let disposeBag = DisposeBag()

    // MARK: - Query
    
