diff --git a/waku/node/v2/quicksim.nim b/waku/node/v2/quicksim.nim index 4c0f67de3..ecf9eea84 100644 --- a/waku/node/v2/quicksim.nim +++ b/waku/node/v2/quicksim.nim @@ -39,6 +39,7 @@ proc handler(topic: string, data: seq[byte]) {.async, gcsafe.} = # TODO: Implement handler logic let res1 = waitFor node2.wakuSubscribe("foobar") +os.sleep(2000) let res2 = waitFor node1.wakuPublish("foobar", "hello world") - +os.sleep(2000) info "Version is", version diff --git a/waku/protocol/v2/waku_protocol.nim b/waku/protocol/v2/waku_protocol.nim index 28d016d88..436eb4678 100644 --- a/waku/protocol/v2/waku_protocol.nim +++ b/waku/protocol/v2/waku_protocol.nim @@ -59,7 +59,7 @@ method subscribeTopic*(w: WakuSub, topic: string, subscribe: bool, peerId: string) {.gcsafe.} = - debug "subscribeTopic" + debug "subscribeTopic", topic=topic, subscribe=subscribe, peerId=peerId procCall FloodSub(w).subscribeTopic(topic, subscribe, peerId) method handleDisconnect*(w: WakuSub, peer: PubSubPeer) {.async.} = @@ -74,7 +74,7 @@ method rpcHandler*(w: WakuSub, method publish*(w: WakuSub, topic: string, data: seq[byte]) {.async.} = - debug "publish" + debug "publish", topic=topic await procCall FloodSub(w).publish(topic, data) method unsubscribe*(w: WakuSub,