diff --git a/libp2p/protocols/connectivity/relay/utils.nim b/libp2p/protocols/connectivity/relay/utils.nim index c5449aa..275a26f 100644 --- a/libp2p/protocols/connectivity/relay/utils.nim +++ b/libp2p/protocols/connectivity/relay/utils.nim @@ -64,15 +64,17 @@ proc bridge*(connSrc: Connection, connDst: Connection) {.async.} = await futSrc or futDst if futSrc.finished(): bufRead = await futSrc - bytesSendFromSrcToDst.inc(bufRead) - await connDst.write(@bufSrcToDst[0.. 0: + bytesSendFromSrcToDst.inc(bufRead) + await connDst.write(@bufSrcToDst[0.. 0: + bytesSendFromDstToSrc += bufRead + await connSrc.write(bufDstToSrc[0..