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 {
8
8
/// Has the connection been closed?
9
9
public private( set) var isClosed = Atomic < Bool > ( value: false )
10
10
11
- internal let redisPipeline : RedisMessenger
11
+ internal let messenger : RedisMessenger
12
12
13
13
private let channel : Channel
14
14
@@ -18,7 +18,7 @@ public final class NIORedisConnection {
18
18
/// - Important: Call `close()` before deinitializing to properly cleanup resources!
19
19
init ( channel: Channel , handler: RedisMessenger ) {
20
20
self . channel = channel
21
- self . redisPipeline = handler
21
+ self . messenger = handler
22
22
}
23
23
24
24
/// Closes the connection to Redis.
@@ -48,7 +48,7 @@ public final class NIORedisConnection {
48
48
let promise = eventLoop. makePromise ( of: RedisData . self)
49
49
50
50
// cascade this enqueue to the newly created promise
51
- redisPipeline . enqueue ( message) . cascade ( promise: promise)
51
+ messenger . enqueue ( message) . cascade ( promise: promise)
52
52
53
53
return promise. futureResult
54
54
}
You can’t perform that action at this time.
0 commit comments