varun-r-mallya/py-libp2p
1
0
Fork 0
mirror of https://github.com/varun-r-mallya/py-libp2p.git synced 2026-02-12 16:10:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge remote-tracking branch 'origin/main' into fix_multiselect_negotiate_type

Browse Source
This commit is contained in:
unniznd
2025-08-25 21:07:49 +05:30
parent 1ecff5437c 292bd1a942
commit cda50e0ead
51 changed files with 2927 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
libp2p/stream_muxer/muxer_multistream.py
View File

@ -17,6 +17,9 @@ from libp2p.custom_types import (
from libp2p.peer.id import (
ID,
)
from libp2p.protocol_muxer.exceptions import (
MultiselectError,
)
from libp2p.protocol_muxer.multiselect import (
Multiselect,
)
@ -84,8 +87,8 @@ class MuxerMultistream:
)
else:
protocol, _ = await self.multiselect.negotiate(communicator)
if protocol is None:
raise MuxerUpgradeFailure("No protocol selected")
if protocol is None:
raise MultiselectError("fail to negotiate a stream muxer protocol")
return self.transports[protocol]
async def new_conn(self, conn: ISecureConn, peer_id: ID) -> IMuxedConn: