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

Fix linting issue

Browse Source
This commit is contained in:
Stuckinaboot 2019-02-28 19:17:11 -05:00
parent 4298b0631f
commit 66703bd414
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
tests/libp2p/test_notify.py
View File

@ -1,26 +1,23 @@
import multiaddr import pytest
import pytest, asyncio
from tests.utils import cleanup from tests.utils import cleanup
from libp2p import new_node from libp2p import new_node
from libp2p.peer.peerinfo import info_from_p2p_addr
from libp2p.network.notifee_interface import INotifee from libp2p.network.notifee_interface import INotifee
# pylint: disable=too-many-locals # pylint: disable=too-many-locals
""" """
Test Notify and Notifee by ensuring that the proper events get Test Notify and Notifee by ensuring that the proper events get
called at the proper time, and that the stream passed into called, and that the stream passed into opened_stream is correct
opened_stream is correct
Note: Listen event does not get hit because MyNotifee is passed Note: Listen event does not get hit because MyNotifee is passed
into network after network has already started listening into network after network has already started listening
TODO: Add tests to ensure conn is the correct connection TODO: Add tests to ensure conn is the correct connection
TODO: Add tests for closed_stream disconnected, listen_close as those TODO: Add tests for closed_stream disconnected, listen_close when those
features are implemented in network features are implemented in swarm
passed into connected
""" """
class MyNotifee(INotifee): class MyNotifee(INotifee):
# pylint: disable=too-many-instance-attributes, cell-var-from-loop # pylint: disable=too-many-instance-attributes, cell-var-from-loop
@ -173,4 +170,4 @@ async def test_ten_notifiers():
assert response == ("ack:" + message) assert response == ("ack:" + message)
# Success, terminate pending tasks. # Success, terminate pending tasks.
await cleanup() await cleanup()