From 6c99d854dd932cf520f8ce88b8a53eadcac6594c Mon Sep 17 00:00:00 2001 From: Robert Zajac Date: Sun, 25 Nov 2018 15:27:54 -0500 Subject: [PATCH] fixes for muxed_conn interface and usage of self.buffers over self.stream --- stream_muxer/mplex/mplex_stream.py | 4 ++-- stream_muxer/muxed_connection_interface.py | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/stream_muxer/mplex/mplex_stream.py b/stream_muxer/mplex/mplex_stream.py index 417ef647..0a505d26 100644 --- a/stream_muxer/mplex/mplex_stream.py +++ b/stream_muxer/mplex/mplex_stream.py @@ -68,7 +68,7 @@ class MplexStream(IMuxedStream): if remote_lock: async with self.mplex_conn.conn_lock: - self.mplex_conn.streams.pop(self.stream_id) + self.mplex_conn.buffers.pop(self.stream_id) return True @@ -91,7 +91,7 @@ class MplexStream(IMuxedStream): self.remote_closed = True async with self.mplex_conn.conn_lock: - self.mplex_conn.streams.pop(self.stream_id, None) + self.mplex_conn.buffers.pop(self.stream_id, None) return True diff --git a/stream_muxer/muxed_connection_interface.py b/stream_muxer/muxed_connection_interface.py index 7a22970f..489615a2 100644 --- a/stream_muxer/muxed_connection_interface.py +++ b/stream_muxer/muxed_connection_interface.py @@ -23,7 +23,7 @@ class IMuxedConn(ABC): pass @abstractmethod - def open_stream(self, protocol_id, stream_id, peer_id, multi_addr): + def open_stream(self, protocol_id, peer_id, multi_addr): """ creates a new muxed_stream :param protocol_id: protocol_id of stream