updates

datastore/threadproxyds.nim

@@ -82,9 +82,9 @@ method get*(
   var ret = newThreadResult(ValueBuffer)
   proc submitGet() =
     let bkey = KeyBuffer.new(key)
-    echo "\n"
-    echo "get:bkey: ", $key, " => ", bkey.toString(), " :: ", bkey.repr()
-    echo "\n"
+    # echo "\n"
+    # echo "get:bkey: ", $key, " => ", bkey.toString(), " :: ", bkey.repr()
+    # echo "\n"
     self.tds[].tp.spawn getTask(sig, ret, self.tds, bkey)
 
   submitGet()

datastore/threads/threadbackend.nim

@@ -110,7 +110,6 @@ proc getTask*(
   tds: ThreadDatastorePtr,
   kb: KeyBuffer,
 ) =
-  echo "\n"
   echoed "getTask: ", $getThreadId(), " kb: ", kb.repr
   let key = kb.toKey()
   echoed "getTask: key: ", $key
@@ -138,7 +137,6 @@ proc putTask*(
 
   # os.sleep(1_000)
   # var ret = ret
-  echo "\n"
   echoed "putTask: ", $getThreadId()
   echoed "putTask:kb: ", kb.toString
   echoed "putTask:db: ", db.toString

tests/datastore/testthreadproxyds.nim

@@ -37,20 +37,20 @@ suite "Test Basic ThreadProxyDatastore":
   test "check put":
     # echo "\n\n=== put ==="
     let res1 = await sds.put(key1, data)
-    echo "res1: ", res1.repr
+    # echo "res1: ", res1.repr
     check res1.isOk
 
   test "check get":
-    echo "\n\n=== get ==="
-    echo "get send key: ", key1.repr
+    # echo "\n\n=== get ==="
+    # echo "get send key: ", key1.repr
     let res2 = await sds.get(key1)
-    echo "get key post: ", key1.repr
-    echo "get res2: ", res2.repr
+    # echo "get key post: ", key1.repr
+    # echo "get res2: ", res2.repr
     # echo res2.get() == data
     var val = ""
     for c in res2.get():
       val &= char(c)
-    print "get res2: ", $val
+    # print "get res2: ", $val
 
     # echo "\n\n=== put cancel ==="
     # # let res1 = await sds.put(key1, "value for 1".toBytes())