mirror of
https://github.com/logos-storage/nim-datastore.git
synced 2026-01-07 16:13:07 +00:00
more changes
This commit is contained in:
parent
972ee22efd
commit
ec4b442125
@ -82,8 +82,9 @@ func new*[S: ref Datastore](
|
|||||||
|
|
||||||
var
|
var
|
||||||
self = SharedDatastore()
|
self = SharedDatastore()
|
||||||
signal = newSignal()
|
|
||||||
res = TResult[ThreadDatastore].new()
|
res = TResult[ThreadDatastore].new()
|
||||||
self.tds = ThreadDatastore.new(signal, backend, res)
|
|
||||||
|
res[].signal = newSignal()
|
||||||
|
self.tds = ThreadDatastore.new(backend, res)
|
||||||
|
|
||||||
success self
|
success self
|
||||||
|
|||||||
@ -86,7 +86,6 @@ proc getTask*(
|
|||||||
key: KeyBuffer,
|
key: KeyBuffer,
|
||||||
ret: TResult[DataBuffer]
|
ret: TResult[DataBuffer]
|
||||||
) =
|
) =
|
||||||
|
|
||||||
# return ok(DataBuffer.new())
|
# return ok(DataBuffer.new())
|
||||||
discard
|
discard
|
||||||
|
|
||||||
@ -108,7 +107,7 @@ proc putTask*(
|
|||||||
# except Exception as exc:
|
# except Exception as exc:
|
||||||
# return TResult[void].new()
|
# return TResult[void].new()
|
||||||
|
|
||||||
func new*[S: ref Datastore](
|
func new*(
|
||||||
T: typedesc[ThreadDatastore],
|
T: typedesc[ThreadDatastore],
|
||||||
signal: ThreadSignalPtr,
|
signal: ThreadSignalPtr,
|
||||||
backend: ThreadBackend,
|
backend: ThreadBackend,
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user