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

read buffer and write_to_stream return

Browse Source
This commit is contained in:
Alex Haynes
2018-11-11 17:48:31 -05:00
parent 162f54af0c
commit e44e31e55b
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
muxer/mplex/muxed_connection.py
View File

@ -33,6 +33,11 @@ class MuxedConn(IMuxedConn):
""" """
pass pass
def read_buffer(self, stream_id):
data = self.buffers[stream_id]
self.buffers[stream_id] = bytearray()
return data
def open_stream(self, protocol_id, stream_id, peer_id, multi_addr): def open_stream(self, protocol_id, stream_id, peer_id, multi_addr):
""" """
creates a new muxed_stream creates a new muxed_stream
@ -67,9 +72,9 @@ class MuxedConn(IMuxedConn):
return self.write_to_stream(_bytes) return self.write_to_stream(_bytes)
async def write_to_stream(self, _bytes): async def write_to_stream(self, _bytes):
to_return = self.raw_conn.writer.write(_bytes) self.raw_conn.writer.write(_bytes)
await self.raw_conn.writer.drain() await self.raw_conn.writer.drain()
return to_return return len(_bytes)
async def handle_incoming(self): async def handle_incoming(self):
data = bytearray() data = bytearray()