Moves all RxSwift dependency to GraphQLRxSwift

Author: Jay Herron

Package.swift

@@ -8,16 +8,14 @@ let package = Package(
     ],
     dependencies: [
         .package(url: "https://github.com/apple/swift-nio.git", .upToNextMajor(from: "2.10.1")),
-        .package(url: "https://github.com/wickwirew/Runtime.git", .upToNextMinor(from: "2.1.0")),
-        .package(url: "https://github.com/ReactiveX/RxSwift.git", .upToNextMajor(from: "6.1.0"))
+        .package(url: "https://github.com/wickwirew/Runtime.git", .upToNextMinor(from: "2.1.0"))
     ],
     targets: [
         .target(
             name: "GraphQL", 
             dependencies: [
                 .product(name: "NIO", package: "swift-nio"),
-                .product(name: "Runtime", package: "Runtime"),
-                .product(name: "RxSwift", package: "RxSwift")
+                .product(name: "Runtime", package: "Runtime")
             ]
         ),
         .testTarget(name: "GraphQLTests", dependencies: ["GraphQL"]),

Sources/GraphQL/Subscription/EventStream.swift

@@ -1,7 +1,3 @@
-// Copyright (c) 2021 PassiveLogic, Inc.
-
-import RxSwift
-
 /// Abstract event stream class - Should be overridden for actual implementations
 open class EventStream<Element> {
     public init() { }
@@ -10,74 +6,3 @@ open class EventStream<Element> {
         fatalError("This function should be overridden by implementing classes")
     }
 }
-
-
-// TODO: Put in separate GraphQLRxSwift package
-
-// EventStream wrapper for Observable
-public class ObservableEventStream<Element> : EventStream<Element> {
-    public var observable: Observable<Element>
-    init(_ observable: Observable<Element>) {
-        self.observable = observable
-    }
-    override open func map<To>(_ closure: @escaping (Element) throws -> To) -> EventStream<To> {
-        return ObservableEventStream<To>(observable.map(closure))
-    }
-}
-// Convenience types
-public typealias ObservableSourceEventStream = ObservableEventStream<Future<Any>>
-public typealias ObservableSubscriptionEventStream = ObservableEventStream<Future<GraphQLResult>>
-
-extension Observable {
-    // Convenience method for wrapping Observables in EventStreams
-    public func toEventStream() -> ObservableEventStream<Element> {
-        return ObservableEventStream(self)
-    }
-}
-
-
-// TODO: Delete notes below
-
-// Protocol attempts
-
-//protocol EventStreamP {
-//    associatedtype Element
-//    func transform<To>(_ closure: @escaping (Element) throws -> To) -> EventStreamP // How to specify that returned associated type is 'To'
-//}
-//extension Observable: EventStreamP {
-//    func transform<To>(_ closure: @escaping (Element) throws -> To) -> EventStreamP {
-//        return self.map(closure)
-//    }
-//}
-
-// Try defining element in closure return
-//protocol EventStreamP {
-//    associatedtype Element
-//    func transform<ResultStream: EventStreamP>(_ closure: @escaping (Element) throws -> ResultStream.Element) -> ResultStream
-//}
-//extension Observable: EventStreamP {
-//    func transform<ResultStream: EventStreamP>(_ closure: @escaping (Element) throws -> ResultStream.Element) -> ResultStream {
-//        return self.map(closure) // Observable<ResultStream.Element> isn't recognized as a ResultStream
-//    }
-//}
-
-// Try absorbing generic type into function
-//protocol EventStreamP {
-//    func transform<From, To>(_ closure: @escaping (From) throws -> To) -> EventStreamP
-//}
-//extension Observable: EventStreamP {
-//    func transform<From, To>(_ closure: @escaping (From) throws -> To) -> EventStreamP {
-//        return self.map(closure) // Doesn't recognize that Observable.Element is the same as From
-//    }
-//}
-
-// Try opaque types
-//protocol EventStreamP {
-//    associatedtype Element
-//    func transform<To>(_ closure: @escaping (Element) throws -> To) -> some EventStreamP
-//}
-//extension Observable: EventStreamP {
-//    func transform<To>(_ closure: @escaping (Element) throws -> To) -> some EventStreamP {
-//        return self.map(closure)
-//    }
-//}