Use SwiftNIO 2.0 development

Author: Mordil

Package.swift

@@ -9,7 +9,7 @@ let package = Package(
         //.library(name: "Redis", targets: [""])
     ],
     dependencies: [
-        .package(url: "https://github.com/apple/swift-nio.git", from: "1.0.0")
+        .package(url: "https://github.com/apple/swift-nio.git", .branch("master"))
     ],
     targets: [
         .target(name: "NIORedis", dependencies: ["NIO"]),

Tests/NIORedisTests/Data/RedisDataDecoder+ByteToMessageDecoderTests.swift

@@ -57,8 +57,9 @@ final class RedisDataDecoderByteToMessageDecoderTests: XCTestCase {
     private func decodeTest(_ input: String, buffer: inout ByteBuffer) throws -> DecodingState {
         let embeddedChannel = EmbeddedChannel()
         defer { _ = try? embeddedChannel.finish() }
-        try embeddedChannel.pipeline.add(handler: decoder).wait()
-        let context = try embeddedChannel.pipeline.context(handler: decoder).wait()
+        let handler = ByteToMessageHandler(decoder)
+        try embeddedChannel.pipeline.add(handler: handler).wait()
+        let context = try embeddedChannel.pipeline.context(handler: handler).wait()
 
         buffer.write(string: input)
 

Tests/NIORedisTests/Data/RedisDataDecoderTests.swift

@@ -109,7 +109,8 @@ final class RedisDataDecoderTests: XCTestCase {
     private func runTest(_ input: Data) throws -> (RedisData?, RedisData?) {
         let embeddedChannel = EmbeddedChannel()
         defer { _ = try? embeddedChannel.finish() }
-        try embeddedChannel.pipeline.add(handler: decoder).wait()
+        let handler = ByteToMessageHandler(decoder)
+        try embeddedChannel.pipeline.add(handler: handler).wait()
         var buffer = allocator.buffer(capacity: 256)
         buffer.write(bytes: input)
         try embeddedChannel.writeInbound(buffer)
@@ -170,7 +171,8 @@ extension RedisDataDecoderTests {
     func test_all() throws {
         let embeddedChannel = EmbeddedChannel()
         defer { _ = try? embeddedChannel.finish() }
-        try embeddedChannel.pipeline.add(handler: decoder).wait()
+        let handler = ByteToMessageHandler(decoder)
+        try embeddedChannel.pipeline.add(handler: handler).wait()
 
         var buffer = allocator.buffer(capacity: 256)
         for message in AllData.messages {