 import RxSwift
 @testable import Graphiti
 
-let pubsub = PublishSubject<User>()
+let pubsub = PublishSubject<Any>()
 
 struct ID : Codable {
     let id: String

        wait(for: [expectation], timeout: 10)
    }
    
    // TODO Adjust this to expect an Observable when GraphQL is piped up correctly.
    func testSubscription() throws {
        let subscription = """
        subscription {
            subscribeUser {

        User(arguments.user)
    }
    
    func subscribeUser(context: HelloContext, arguments: NoArguments) -> Observable<Any> {
        pubsub
    }
}
