diff --git a/libp2p/stream_muxer/mplex/mplex.py b/libp2p/stream_muxer/mplex/mplex.py index 5e265b96..b3b45c05 100644 --- a/libp2p/stream_muxer/mplex/mplex.py +++ b/libp2p/stream_muxer/mplex/mplex.py @@ -66,7 +66,7 @@ class Mplex(IMuxedConn): self.streams = {} self.streams_lock = trio.Lock() self.streams_msg_channels = {} - channels = trio.open_memory_channel[IMuxedStream](math.inf) + channels = trio.open_memory_channel[IMuxedStream](0) self.new_stream_send_channel, self.new_stream_receive_channel = channels self.event_shutting_down = trio.Event() self.event_closed = trio.Event()