diff options
Diffstat (limited to 'packages/meshbay-node/tests')
| -rw-r--r-- | packages/meshbay-node/tests/test_transfer_slots_wire.py | 7 |
1 files changed, 4 insertions, 3 deletions
diff --git a/packages/meshbay-node/tests/test_transfer_slots_wire.py b/packages/meshbay-node/tests/test_transfer_slots_wire.py index d96456c..6e9ef94 100644 --- a/packages/meshbay-node/tests/test_transfer_slots_wire.py +++ b/packages/meshbay-node/tests/test_transfer_slots_wire.py @@ -329,13 +329,14 @@ async def test_the_sweeper_stops_when_the_last_lease_goes(ctx): import asyncio from meshbay_node.transport import webrtc_server as ws + from meshbay_node.transport.webrtc import transfer_handlers peer = _join(ctx, "s1", "alice") peer._tasks = set() peer._spawn = ws.WebRTCPeerSession._spawn.__get__(peer) - original = ws.TRANSFER_SWEEP_SECS - ws.TRANSFER_SWEEP_SECS = 0.01 + original = transfer_handlers.TRANSFER_SWEEP_SECS + transfer_handlers.TRANSFER_SWEEP_SECS = 0.01 try: peer._do_transfer_open({"tr": "t1"}) peer._do_transfer_close({"tr": "t1"}) @@ -343,7 +344,7 @@ async def test_the_sweeper_stops_when_the_last_lease_goes(ctx): await asyncio.wait_for(sweeper, timeout=2) assert ctx.get("_transfer_sweeper") is None finally: - ws.TRANSFER_SWEEP_SECS = original + transfer_handlers.TRANSFER_SWEEP_SECS = original async def test_a_chunk_request_keeps_its_lease_alive(ctx): |