This commit is contained in:
meejah 2022-09-27 16:31:43 -06:00
parent aeae7c2bdd
commit 2f6ada10ad

View File

@ -108,12 +108,18 @@ class Receiver(WebSocketClientProtocol):
class TransitWebSockets(unittest.TestCase): class TransitWebSockets(unittest.TestCase):
"""
Integration-style tests of the transit WebSocket relay, using the
real reactor (and running transit as a subprocess).
"""
@inlineCallbacks @inlineCallbacks
def test_buffer_fills(self): def test_buffer_fills(self):
""" """
A running transit relay stops accepting incoming data if the peer A running transit relay stops accepting incoming data at a
isn't reading. reasonable amount if the peer isn't reading. This test defines
that as 'less than 100MiB' although in practice Twisted seems
to stop before 10MiB.
""" """
from twisted.internet import reactor from twisted.internet import reactor
transit_proto = _CollectOutputProtocol() transit_proto = _CollectOutputProtocol()