Conform RedisByteDecoder to NIOSingleStepByteToMessageDecoder (#63)

Author: fabianfett

Sources/RediStack/ChannelHandlers/RedisByteDecoder.swift

@@ -2,7 +2,7 @@
 //
 // This source file is part of the RediStack open source project
 //
-// Copyright (c) 2019 RediStack project authors
+// Copyright (c) 2019-2022 RediStack project authors
 // Licensed under Apache License v2.0
 //
 // See LICENSE.txt for license information
@@ -17,8 +17,8 @@ import NIOCore
 /// Handles incoming byte messages from Redis
 /// and decodes them according to the Redis Serialization Protocol (RESP).
 ///
-/// See `NIO.ByteToMessageDecoder`, `RESPTranslator` and [https://redis.io/topics/protocol](https://redis.io/topics/protocol)
-public final class RedisByteDecoder: ByteToMessageDecoder {
+/// See `NIO.NIOSingleStepByteToMessageDecoder`, `RESPTranslator` and [https://redis.io/topics/protocol](https://redis.io/topics/protocol)
+public final class RedisByteDecoder: NIOSingleStepByteToMessageDecoder {
     /// `ByteToMessageDecoder.InboundOut`
     public typealias InboundOut = RESPValue
 
@@ -28,18 +28,13 @@ public final class RedisByteDecoder: ByteToMessageDecoder {
         self.parser = RESPTranslator()
     }
 
-    /// See `ByteToMessageDecoder.decode(context:buffer:)`
-    public func decode(context: ChannelHandlerContext, buffer: inout ByteBuffer) throws -> DecodingState {
-        guard let value = try self.parser.parseBytes(from: &buffer) else { return .needMoreData }
-        
-        context.fireChannelRead(wrapInboundOut(value))
-        return .continue
+    /// See `NIOSingleStepByteToMessageDecoder.decode(buffer:)`
+    public func decode(buffer: inout ByteBuffer) throws -> RESPValue? {
+        try self.parser.parseBytes(from: &buffer)
     }
 
-    /// See `ByteToMessageDecoder.decodeLast(context:buffer:seenEOF)`
-    public func decodeLast(
-        context: ChannelHandlerContext,
-        buffer: inout ByteBuffer,
-        seenEOF: Bool
-    ) throws -> DecodingState { return .needMoreData }
+    /// See `NIOSingleStepByteToMessageDecoder.decodeLast(buffer:seenEOF)`
+    public func decodeLast(buffer: inout ByteBuffer, seenEOF: Bool) throws -> RESPValue? {
+        try self.decode(buffer: &buffer)
+    }
 }