From c656ce8cb4b664717effc8c1ef21a40e9a01cb2b Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 5 Sep 2023 16:24:59 -0700 Subject: [PATCH] back to release --- datastore/threadproxyds.nim | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/datastore/threadproxyds.nim b/datastore/threadproxyds.nim index 07960d6..adafb1e 100644 --- a/datastore/threadproxyds.nim +++ b/datastore/threadproxyds.nim @@ -34,7 +34,7 @@ method has*( has(ret, self.tds, key) await wait(ret[].signal) finally: - ret[].signal.close() + ret[].signal.release() return ret.convert(bool) @@ -49,7 +49,7 @@ method delete*( delete(ret, self.tds, key) await wait(ret[].signal) finally: - ret[].signal.close() + ret[].signal.release() return ret.convert(void) @@ -80,7 +80,7 @@ method get*( get(ret, self.tds, key) await wait(ret[].signal) finally: - ret[].signal.close() + ret[].signal.release() return ret.convert(seq[byte]) @@ -96,7 +96,7 @@ method put*( put(ret, self.tds, key, data) await wait(ret[].signal) finally: - ret[].signal.close() + ret[].signal.release() return ret.convert(void) @@ -155,7 +155,7 @@ method query*( proc dispose(): Future[?!void] {.async.} = iter[].it = nil # ensure our sharedptr doesn't try and dealloc - ret[].signal.close() + ret[].signal.release() return success() iterWrapper.next = next