From ffc3fb059fbd4080b727aff31cc1dd4d402f9397 Mon Sep 17 00:00:00 2001 From: Alex Haynes Date: Sun, 11 Nov 2018 18:01:08 -0500 Subject: [PATCH] updated open stream --- muxer/mplex/muxed_connection.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/muxer/mplex/muxed_connection.py b/muxer/mplex/muxed_connection.py index e6d5819..fdae239 100644 --- a/muxer/mplex/muxed_connection.py +++ b/muxer/mplex/muxed_connection.py @@ -1,7 +1,7 @@ import asyncio from .utils import encode_uvarint, decode_uvarint from .muxed_connection_interface import IMuxedConn -from transport.stream.Stream import Stream +from .muxed_stream import MuxedStream class MuxedConn(IMuxedConn): """ @@ -43,7 +43,7 @@ class MuxedConn(IMuxedConn): creates a new muxed_stream :return: a new stream """ - stream = Stream(peer_id, multi_addr, self) + stream = MuxedStream(peer_id, multi_addr, self) self.streams[stream_id] = stream self.buffers[stream_id] = bytearray() return stream