From f1d2a0ed2656a6e6746ada2eccc33c1f006cb0b9 Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 29 Aug 2023 15:57:15 -0700 Subject: [PATCH] implementing query type --- datastore/threadproxyds.nim | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/datastore/threadproxyds.nim b/datastore/threadproxyds.nim index 115bd5e..ad250eb 100644 --- a/datastore/threadproxyds.nim +++ b/datastore/threadproxyds.nim @@ -142,7 +142,7 @@ method query*( self.tds[].tp.spawn queryTask(ret, self.tds, iter) await wait(ret[].signal) - iter[].it = nil # ensure our sharedptr doesn't try and dealloc + # iter[].it = nil # ensure our sharedptr doesn't try and dealloc finally: ret[].signal.close() @@ -162,7 +162,7 @@ method close*( ## this can block... how to handle? maybe just leak? self.tds[].tp.shutdown() - self[].tds[].ds = nil # ensure our sharedptr doesn't try and dealloc + # self[].tds[].ds = nil # ensure our sharedptr doesn't try and dealloc proc newThreadProxyDatastore*( ds: Datastore,