File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed
Sources/NIORedis/ChannelHandlers Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -6,11 +6,11 @@ public struct RedisCommandContext {
6
6
/// A full command keyword and arguments stored as a single `RESPValue`.
7
7
public let command : RESPValue
8
8
/// A promise expected to be fulfilled with the `RESPValue` response to the command from Redis.
9
- public let promise : EventLoopPromise < RESPValue >
9
+ public let responsePromise : EventLoopPromise < RESPValue >
10
10
11
11
public init ( command: RESPValue , promise: EventLoopPromise < RESPValue > ) {
12
12
self . command = command
13
- self . promise = promise
13
+ self . responsePromise = promise
14
14
}
15
15
}
16
16
@@ -77,7 +77,7 @@ extension RedisCommandHandler: ChannelOutboundHandler {
77
77
/// See `ChannelOutboundHandler.write(ctx:data:promise:)`
78
78
public func write( ctx: ChannelHandlerContext , data: NIOAny , promise: EventLoopPromise < Void > ? ) {
79
79
let context = unwrapOutboundIn ( data)
80
- commandResponseQueue. insert ( context. promise , at: 0 )
80
+ commandResponseQueue. insert ( context. responsePromise , at: 0 )
81
81
ctx. write ( wrapOutboundOut ( context. command) , promise: promise)
82
82
}
83
83
}
You can’t perform that action at this time.
0 commit comments