This commit is contained in:
Jaremy Creechley 2023-08-28 17:28:14 -07:00
parent 216a5ea518
commit 2e0e4d18cc
No known key found for this signature in database
GPG Key ID: 4E66FB67B21D3300
2 changed files with 2 additions and 4 deletions

View File

@ -83,7 +83,6 @@ method put*(
echo "\nSharedDataStore:put:value: ", ret[].repr echo "\nSharedDataStore:put:value: ", ret[].repr
return success() return success()
method put*( method put*(
self: SharedDatastore, self: SharedDatastore,
batch: seq[BatchEntry] batch: seq[BatchEntry]
@ -93,7 +92,6 @@ method put*(
method close*( method close*(
self: SharedDatastore self: SharedDatastore
): Future[?!void] {.async.} = ): Future[?!void] {.async.} =
# TODO: how to handle failed close? # TODO: how to handle failed close?
return success() return success()

View File

@ -108,7 +108,7 @@ proc startupDatastore(
else: else:
discard discard
echo "startupDatastore: signal", ret[].signal.fireSync().get() print "startupDatastore: signal", ret[].signal.fireSync()
proc getTask*( proc getTask*(
ret: TResult[DataBuffer], ret: TResult[DataBuffer],
@ -123,7 +123,7 @@ proc getTask*(
ret[].state = Success ret[].state = Success
ret[].value = data ret[].value = data
print "thrbackend: putTask: fire", ret[].signal.fireSync().get() print "thrbackend: putTask: fire", ret[].signal.fireSync()
proc get*( proc get*(
ret: TResult[DataBuffer], ret: TResult[DataBuffer],