Update DispatchRedis module with new classes

Author: Mordil

Sources/DispatchRedis/Redis.swift

@@ -4,12 +4,12 @@ import NIORedis
 
 /// A factory that handles all necessary details for creating `RedisConnection` instances.
 public final class Redis {
-    private let driver: NIORedis
+    private let driver: RedisDriver
 
     deinit { try? driver.terminate() }
 
     public init(threadCount: Int = 1) {
-        self.driver = NIORedis(executionModel: .spawnThreads(threadCount))
+        self.driver = RedisDriver(executionModel: .spawnThreads(threadCount))
     }
 
     public func makeConnection(

Sources/DispatchRedis/RedisConnection.swift

@@ -2,20 +2,20 @@ import Foundation
 import NIORedis
 
 public final class RedisConnection {
-    let _driverConnection: NIORedisConnection
+    let _driverConnection: NIORedis.RedisConnection
 
     private let queue: DispatchQueue
 
     deinit { _driverConnection.close() }
 
-    init(driver: NIORedisConnection, callbackQueue: DispatchQueue) {
+    init(driver: NIORedis.RedisConnection, callbackQueue: DispatchQueue) {
         self._driverConnection = driver
         self.queue = callbackQueue
     }
 
     /// Creates a `RedisPipeline` for executing a batch of commands.
     public func makePipeline(callbackQueue: DispatchQueue? = nil) -> RedisPipeline {
-        return .init(using: self, callbackQueue: callbackQueue ?? queue)
+        return .init(connection: self, callbackQueue: callbackQueue ?? queue)
     }
 
     public func get(

Sources/DispatchRedis/RedisPipeline.swift

@@ -14,15 +14,15 @@ import NIORedis
 /// - Important: The larger the pipeline queue, the more memory both the Redis driver and Redis server will use.
 /// See https://redis.io/topics/pipelining#redis-pipelining
 public final class RedisPipeline {
-    private let _driverPipeline: NIORedisPipeline
+    private let _driverPipeline: NIORedis.RedisPipeline
     private let queue: DispatchQueue
 
     /// Creates a new pipeline queue using the provided `RedisConnection`, executing callbacks on the provided `DispatchQueue`.
     /// - Parameters:
     ///     - using: The connection to execute the commands on.
     ///     - callbackQueue: The queue to execute all callbacks on.
-    public init(using connection: RedisConnection, callbackQueue: DispatchQueue) {
-        self._driverPipeline = NIORedisPipeline(using: connection._driverConnection)
+    public init(connection: RedisConnection, callbackQueue: DispatchQueue) {
+        self._driverPipeline = NIORedis.RedisPipeline(channel: connection._driverConnection.channel)
         self.queue = callbackQueue
     }