diff --git a/datastore/sharedds.nim b/datastore/sharedds.nim index 8c2d2a7..92d82e5 100644 --- a/datastore/sharedds.nim +++ b/datastore/sharedds.nim @@ -83,7 +83,6 @@ method put*( echo "\nSharedDataStore:put:value: ", ret[].repr return success() - method put*( self: SharedDatastore, batch: seq[BatchEntry] @@ -93,7 +92,6 @@ method put*( method close*( self: SharedDatastore ): Future[?!void] {.async.} = - # TODO: how to handle failed close? return success() diff --git a/datastore/threadbackend.nim b/datastore/threadbackend.nim index 32bdec5..75e1d94 100644 --- a/datastore/threadbackend.nim +++ b/datastore/threadbackend.nim @@ -108,7 +108,7 @@ proc startupDatastore( else: discard - echo "startupDatastore: signal", ret[].signal.fireSync().get() + print "startupDatastore: signal", ret[].signal.fireSync() proc getTask*( ret: TResult[DataBuffer], @@ -123,7 +123,7 @@ proc getTask*( ret[].state = Success ret[].value = data - print "thrbackend: putTask: fire", ret[].signal.fireSync().get() + print "thrbackend: putTask: fire", ret[].signal.fireSync() proc get*( ret: TResult[DataBuffer],