Adds full conformance to the RedisClient protocol to use the context's eventLoop for commands vs the default RedisConnectionPools eventLoop for commands. (#27)

Andrewangeta · web-flow · commit 2728477b50e2 · 2021-05-19T13:29:28.000-04:00
diff --git a/Sources/QueuesRedisDriver/JobsRedisDriver.swift b/Sources/QueuesRedisDriver/JobsRedisDriver.swift
@@ -102,6 +102,10 @@ extension _QueuesRedisQueue: RedisClient {
         return true
     }
     
+    var eventLoop: EventLoop {
+        self.context.eventLoop
+    }
+    
     func send(command: String, with arguments: [RESPValue]) -> EventLoopFuture<RESPValue> {
         self.client.send(command: command, with: arguments)
     }

Original file line number	Diff line number	Diff line change
`@@ -102,6 +102,10 @@ extension _QueuesRedisQueue: RedisClient {`
`102`	`102`	`return true`
`103`	`103`	`}`
`104`	`104`
	`105`	`+ var eventLoop: EventLoop {`
	`106`	`+ self.context.eventLoop`
	`107`	`+ }`
	`108`	`+`
`105`	`109`	`func send(command: String, with arguments: [RESPValue]) -> EventLoopFuture<RESPValue> {`
`106`	`110`	`self.client.send(command: command, with: arguments)`
`107`	`111`	`}`