Changeset d2ea9c5 in trunk

Timestamp:

2019-05-30T23:30:28Z (6 years ago)

Author:

meejah <meejah@…>

Branches:

master

Children:

8938d55

Parents:

811c7ea

git-author:

meejah <meejah@…> (2019-04-24 21:27:10)

git-committer:

meejah <meejah@…> (2019-05-30 23:30:28)

Message:

get rid of flush() calls

File:

• src/allmydata/test/test_websocket_logs.py (modified) (3 diffs)

src/allmydata/test/test_websocket_logs.py ¶

@@ -6 +6 @@
 from eliot import log_call
 
-from autobahn.twisted.testing import create_memory_agent, MemoryReactorClockResolver
+from autobahn.twisted.testing import create_memory_agent, MemoryReactorClockResolver, create_pumper
 from autobahn.twisted.websocket import WebSocketServerProtocol
 from autobahn.twisted.websocket import WebSocketClientProtocol
@@ -22 +22 @@
     def setUp(self):
         self.reactor = MemoryReactorClockResolver()
-        self.agent = create_memory_agent(self.reactor, TokenAuthenticatedWebSocketServerProtocol)
+        self.pumper = create_pumper()
+        self.agent = create_memory_agent(self.reactor, self.pumper, TokenAuthenticatedWebSocketServerProtocol)
+        return self.pumper.start()
+
+    def tearDown(self):
+        return self.pumper.stop()
 
     @inlineCallbacks
@@ -45 +50 @@
 
         proto.transport.loseConnection()
-        self.agent.flush()
         yield proto.is_closed