WIP: try some Autobahn websocket tests #606
|
@ -26,20 +26,9 @@ class TestStreamingLogs(unittest.TestCase):
|
||||||
@inlineCallbacks
|
@inlineCallbacks
|
||||||
def test_one_log(self):
|
def test_one_log(self):
|
||||||
|
|
||||||
class TestClient(WebSocketClientProtocol):
|
|
||||||
def onOpen(self):
|
|
||||||
print("opened")
|
|
||||||
|
|
||||||
def onMessage(self, msg, is_binary=False):
|
|
||||||
print("msg {}".format(msg))
|
|
||||||
|
|
||||||
def onClose(self, *args):
|
|
||||||
print("close: {}".format(args))
|
|
||||||
|
|
||||||
proto = yield self.agent.open(
|
proto = yield self.agent.open(
|
||||||
transport_config=u"ws://localhost:1234/ws",
|
transport_config=u"ws://localhost:1234/ws",
|
||||||
options={},
|
options={},
|
||||||
protocol_class=None,
|
|
||||||
)
|
)
|
||||||
|
|
||||||
messages = []
|
messages = []
|
||||||
|
|
Loading…
Reference in New Issue