File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -8,7 +8,7 @@ public final class NIORedisConnection {
88 /// Has the connection been closed?
99 public private( set) var isClosed = Atomic < Bool > ( value: false )
1010
11- internal let redisPipeline : RedisMessenger
11+ internal let messenger : RedisMessenger
1212
1313 private let channel : Channel
1414
@@ -18,7 +18,7 @@ public final class NIORedisConnection {
1818 /// - Important: Call `close()` before deinitializing to properly cleanup resources!
1919 init ( channel: Channel , handler: RedisMessenger ) {
2020 self . channel = channel
21- self . redisPipeline = handler
21+ self . messenger = handler
2222 }
2323
2424 /// Closes the connection to Redis.
@@ -48,7 +48,7 @@ public final class NIORedisConnection {
4848 let promise = eventLoop. makePromise ( of: RedisData . self)
4949
5050 // cascade this enqueue to the newly created promise
51- redisPipeline . enqueue ( message) . cascade ( promise: promise)
51+ messenger . enqueue ( message) . cascade ( promise: promise)
5252
5353 return promise. futureResult
5454 }
You can’t perform that action at this time.
0 commit comments