Merge pull request #4 from NeedleInAJayStack/fix/ScalarInput

Updates for compliance with Graphiti 1.0.0 EventStream changes

Author: NeedleInAJayStack

Package.resolved

@@ -7,9 +7,9 @@ let package = Package(
         .library(name: "GraphQLRxSwift", targets: ["GraphQLRxSwift"]),
     ],
     dependencies: [
-        .package(url: "https://github.com/GraphQLSwift/GraphQL.git", .upToNextMajor(from: "2.0.0")),
-        .package(url: "https://github.com/GraphQLSwift/Graphiti.git", .upToNextMajor(from: "0.22.0")),
-        .package(url: "https://github.com/ReactiveX/RxSwift.git", .upToNextMajor(from: "6.1.0"))
+        .package(url: "https://github.com/GraphQLSwift/GraphQL.git", from: "2.0.0"),
+        .package(url: "https://github.com/GraphQLSwift/Graphiti.git", from: "1.0.0"),
+        .package(url: "https://github.com/ReactiveX/RxSwift.git", from: "6.1.0")
     ],
     targets: [
         .target(name: "GraphQLRxSwift", dependencies: ["GraphQL", "Graphiti", "RxSwift"]),

Package.swift

@@ -5,7 +5,7 @@ import NIO
 import RxSwift
 @testable import GraphQLRxSwift
 
-let pubsub = PublishSubject<Any>()
+let pubsub = PublishSubject<User>()
 
 struct ID : Codable {
     let id: String
@@ -100,7 +100,7 @@ struct HelloResolver {
         User(arguments.user)
     }
 
-    func subscribeUser(context: HelloContext, arguments: NoArguments) -> EventStream<Any> {
+    func subscribeUser(context: HelloContext, arguments: NoArguments) -> EventStream<User> {
         pubsub.toEventStream()
     }
 }