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

Fix linting

Browse Source
This commit is contained in:
mhchia
2019-09-09 17:05:06 +08:00
parent 0ab548aee5
commit df312f3e57
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
libp2p/stream_muxer/mplex/mplex_stream.py
View File

@ -8,6 +8,7 @@ from .datastructures import StreamID
from .exceptions import MplexStreamClosed, MplexStreamEOF, MplexStreamReset from .exceptions import MplexStreamClosed, MplexStreamEOF, MplexStreamReset
if TYPE_CHECKING: if TYPE_CHECKING:
from typing import Any # noqa: F401
from libp2p.stream_muxer.mplex.mplex import Mplex from libp2p.stream_muxer.mplex.mplex import Mplex
@ -67,8 +68,9 @@ class MplexStream(IMuxedStream):
fut.cancel() fut.cancel()
if self.event_reset.is_set(): if self.event_reset.is_set():
raise MplexStreamReset raise MplexStreamReset
done_task = tuple(done)[0] done_task = cast("asyncio.Task[Any]", tuple(done)[0])
if done_task._coro.__qualname__ == "Queue.get": # TODO: `_coro` is not in `asyncio.Task`'s typeshed.
if done_task._coro.__qualname__ == "Queue.get": # type: ignore
data = done_task.result() data = done_task.result()
self._buf.extend(data) self._buf.extend(data)
return return

1
tests/factories.py
View File

@ -15,7 +15,6 @@ from libp2p.security.base_transport import BaseSecureTransport
from libp2p.security.insecure.transport import PLAINTEXT_PROTOCOL_ID, InsecureTransport from libp2p.security.insecure.transport import PLAINTEXT_PROTOCOL_ID, InsecureTransport
import libp2p.security.secio.transport as secio import libp2p.security.secio.transport as secio
from libp2p.stream_muxer.mplex.mplex import Mplex from libp2p.stream_muxer.mplex.mplex import Mplex
from libp2p.stream_muxer.mplex.mplex_stream import MplexStream
from libp2p.typing import TProtocol from libp2p.typing import TProtocol
from tests.configs import LISTEN_MADDR from tests.configs import LISTEN_MADDR
from tests.pubsub.configs import ( from tests.pubsub.configs import (