diff --git a/datastore/sharedds.nim b/datastore/sharedds.nim index 1bc22e0..e68c3fa 100644 --- a/datastore/sharedds.nim +++ b/datastore/sharedds.nim @@ -79,10 +79,11 @@ proc newSharedDataStore*( var self = SharedDatastore() res = newThreadResult(ThreadDatastorePtr) - + res[].signal = ThreadSignalPtr.new().valueOr: return failure newException(DatastoreError, "error creating signal") res.createThreadDatastore(backend) await wait(res[].signal) + res[].signal.close() success self