diff --git a/libp2p/stream_muxer/mplex/mplex_stream.py b/libp2p/stream_muxer/mplex/mplex_stream.py index e90a1d4..a6c2ce2 100644 --- a/libp2p/stream_muxer/mplex/mplex_stream.py +++ b/libp2p/stream_muxer/mplex/mplex_stream.py @@ -132,7 +132,7 @@ class MplexStream(IMuxedStream): flag = ( HeaderTags.ResetInitiator if self.initiator - else HeaderTags.ResetInitiator + else HeaderTags.ResetReceiver ) await self.mplex_conn.send_message(flag, None, self.stream_id)