diff --git a/Sources/NIORedis/ChannelHandlers/RedisCommandHandler.swift b/Sources/NIORedis/ChannelHandlers/RedisCommandHandler.swift index 5f1865e..7e8a7b4 100644 --- a/Sources/NIORedis/ChannelHandlers/RedisCommandHandler.swift +++ b/Sources/NIORedis/ChannelHandlers/RedisCommandHandler.swift @@ -6,11 +6,11 @@ public struct RedisCommandContext { /// A full command keyword and arguments stored as a single `RESPValue`. public let command: RESPValue /// A promise expected to be fulfilled with the `RESPValue` response to the command from Redis. - public let promise: EventLoopPromise + public let responsePromise: EventLoopPromise public init(command: RESPValue, promise: EventLoopPromise) { self.command = command - self.promise = promise + self.responsePromise = promise } } @@ -77,7 +77,7 @@ extension RedisCommandHandler: ChannelOutboundHandler { /// See `ChannelOutboundHandler.write(ctx:data:promise:)` public func write(ctx: ChannelHandlerContext, data: NIOAny, promise: EventLoopPromise?) { let context = unwrapOutboundIn(data) - commandResponseQueue.insert(context.promise, at: 0) + commandResponseQueue.insert(context.responsePromise, at: 0) ctx.write(wrapOutboundOut(context.command), promise: promise) } }