 import RxBlocking
 
 class RxApolloTests: XCTestCase {
+
+    let disposeBag = DisposeBag()
 
     // MARK: - Query
     


        return ApolloStore(cache: cache)
    }
}


        _ = 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()

