StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

typed mplex.utils

Browse Source
This commit is contained in:
Chih Cheng Liang 2019-08-02 17:57:30 +08:00
parent 239a5c88fb
commit b64ed9fd6f
No known key found for this signature in database
GPG Key ID: C86B5E6612B1487A
1 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
libp2p/stream_muxer/mplex/utils.py
View File

@ -1,8 +1,10 @@
import asyncio import asyncio
import struct import struct
from typing import Tuple
def encode_uvarint(number):
def encode_uvarint(number: int) -> bytearray:
"""Pack `number` into varint bytes""" """Pack `number` into varint bytes"""
buf = b"" buf = b""
while True: while True:
@ -16,7 +18,7 @@ def encode_uvarint(number):
return buf return buf
def decode_uvarint(buff, index): def decode_uvarint(buff: bytearray, index: int) -> Tuple[int, int]:
shift = 0 shift = 0
result = 0 result = 0
while True: while True:
@ -30,7 +32,9 @@ def decode_uvarint(buff, index):
return result, index + 1 return result, index + 1
async def decode_uvarint_from_stream(reader, timeout): async def decode_uvarint_from_stream(
reader: asyncio.StreamReader, timeout: float
) -> int:
shift = 0 shift = 0
result = 0 result = 0
while True: while True: