chore: async stop process

Author: kaichaosun

examples/pingpong.nim

@@ -69,16 +69,16 @@ proc main() {.async.} =
   await saro.start()
   await raya.start()
 
-  await sleepAsync(5.seconds)
+  await sleepAsync(10.seconds)
 
   # Perform OOB Introduction: Raya -> Saro
   let raya_bundle = raya.createIntroBundle()
   discard await saro.newPrivateConversation(raya_bundle)
 
   await sleepAsync(20.seconds) # Run for some time 
 
-  saro.stop()
-  raya.stop()
+  await saro.stop()
+  await raya.stop()
 
 
 when isMainModule:

src/chat/client.nim

@@ -291,8 +291,8 @@ proc start*(client: Client) {.async.} =
 
   notice "Client start complete", client = client.getId()
 
-proc stop*(client: Client) =
+proc stop*(client: Client) {.async.} =
   ## Stop the client.
-  client.ds.stop()
+  await client.ds.stop()
   client.isRunning = false
   notice "Client stopped", client = client.getId()

src/chat/delivery/waku_client.nim

@@ -206,3 +206,6 @@ proc getConnectedPeerCount*(client: WakuClient): int =
     if peerInfo.connectedness == Connected:
       inc count
   return count
+
+proc stop*(client: WakuClient) {.async.} =
+  await client.node.stop()