mark readNext() as {.gcsafe.} in order to use w/ threaded mode

redis.nimble

@@ -16,3 +16,4 @@ task docs, "Build documentation":
 
 task test, "Run tests":
   exec "nim c -r tests/main.nim"
+  exec "nim c -r --threads:on tests/main.nim"

src/redis.nim

@@ -259,8 +259,8 @@ proc readSingleString(r: Redis | AsyncRedis): Future[RedisString] {.multisync.}
   result = res.get(redisNil)
   finaliseCommand(r)
 
-proc readNext(r: Redis): RedisList
-proc readNext(r: AsyncRedis): Future[RedisList]
+proc readNext(r: Redis): RedisList {.gcsafe.}
+proc readNext(r: AsyncRedis): Future[RedisList] {.gcsafe.}
 proc readArrayLines(r: Redis | AsyncRedis, countLine: string): Future[RedisList] {.multisync.} =
   if countLine[0] != '*':
     raiseInvalidReply(r, '*', countLine[0])

tests/main.nim

@@ -1,6 +1,6 @@
 import redis, unittest, asyncdispatch
 
-suite "redis tests":
+template syncTests() =
   let r = redis.open("localhost")
   let keys = r.keys("*")
   doAssert keys.len == 0, "Don't want to mess up an existing DB."
@@ -100,6 +100,8 @@ suite "redis tests":
   # delete all keys in the DB at the end of the tests
   discard r.flushdb()
   r.quit()
+suite "redis tests":
+  syncTests()
 
 suite "redis async tests":
   let r = waitFor redis.openAsync("localhost")
@@ -152,4 +154,15 @@ suite "redis async tests":
     waitFor main()
 
   discard waitFor r.flushdb()
-  waitFor r.quit()
+  waitFor r.quit()
+
+
+when compileOption("threads"):
+  proc threadFunc() {.thread.} =
+    suite "redis threaded tests":
+      syncTests()
+
+  var th: Thread[void]
+  createThread(th, threadFunc)
+  joinThread(th)
+