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

updated open stream

Browse Source
This commit is contained in:
Alex Haynes
2018-11-11 18:01:08 -05:00
parent cacbc6c11a
commit ffc3fb059f
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
muxer/mplex/muxed_connection.py
View File

@ -1,7 +1,7 @@
import asyncio import asyncio
from .utils import encode_uvarint, decode_uvarint from .utils import encode_uvarint, decode_uvarint
from .muxed_connection_interface import IMuxedConn from .muxed_connection_interface import IMuxedConn
from transport.stream.Stream import Stream from .muxed_stream import MuxedStream
class MuxedConn(IMuxedConn): class MuxedConn(IMuxedConn):
""" """
@ -43,7 +43,7 @@ class MuxedConn(IMuxedConn):
creates a new muxed_stream creates a new muxed_stream
:return: a new 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.streams[stream_id] = stream
self.buffers[stream_id] = bytearray() self.buffers[stream_id] = bytearray()
return stream return stream