vacp2p/nim-libp2p
1
0
Fork 0
mirror of https://github.com/vacp2p/nim-libp2p.git synced 2025-03-04 01:50:36 +00:00
Code Issues Packages Projects Releases Wiki Activity

move store muxer

Browse Source
This commit is contained in:
Ludovic Chenut 2022-12-23 13:33:53 +01:00
parent 676786b00e
commit 6e2c173848
No known key found for this signature in database
GPG Key ID: D9A59B1907F1D50C
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/upgrademngrs/muxedupgrade.nim
View File

@ -73,9 +73,6 @@ proc mux*(
self.connManager.storeConn(conn) self.connManager.storeConn(conn)
# store it in muxed connections if we have a peer for it
self.connManager.storeMuxer(muxer, muxer.handle()) # store muxer and start read loop
try: try:
await self.identify(muxer) await self.identify(muxer)
except CatchableError as exc: except CatchableError as exc:
@ -84,6 +81,9 @@ proc mux*(
# loop # loop
debug "Could not identify connection", conn, msg = exc.msg debug "Could not identify connection", conn, msg = exc.msg
# store it in muxed connections if we have a peer for it
self.connManager.storeMuxer(muxer, muxer.handle()) # store muxer and start read loop
return muxer return muxer
method upgradeOutgoing*( method upgradeOutgoing*(