diff --git a/datastore/sharedds.nim b/datastore/sharedds.nim index 4c84379..0f0619b 100644 --- a/datastore/sharedds.nim +++ b/datastore/sharedds.nim @@ -81,13 +81,11 @@ proc newSharedDataStore*( self = SharedDatastore() res = newThreadResult(ThreadDatastorePtr) - let buf = DataBuffer.new() + res[].signal = ThreadSignalPtr.new().valueOr: + return failure newException(DatastoreError, "error creating signal") - # res[].signal = ThreadSignalPtr.new().valueOr: - # return failure newException(DatastoreError, "error creating signal") - - # res.createThreadDatastore(backend) - # await wait(res[].signal) - # res[].signal.close() + res.createThreadDatastore(backend) + await wait(res[].signal) + res[].signal.close() success self