if self.final_callback is not None:
message = "Connection closed"
if self.stream.error:
- message = str(self.stream.error)
+ raise self.stream.error
raise HTTPError(599, message)
def _handle_1xx(self, code):
def test_websocket_network_timeout(self):
sock, port = bind_unused_port()
sock.close()
- with self.assertRaises(HTTPError) as cm:
+ with self.assertRaises(IOError) as cm:
with ExpectLog(gen_log, ".*"):
yield websocket_connect(
'ws://localhost:%d/' % port,
io_loop=self.io_loop,
connect_timeout=0.01)
- self.assertEqual(cm.exception.code, 599)
@gen_test
def test_websocket_network_fail(self):
sock, port = bind_unused_port()
sock.close()
- with self.assertRaises(HTTPError) as cm:
+ with self.assertRaises(IOError) as cm:
with ExpectLog(gen_log, ".*"):
yield websocket_connect(
'ws://localhost:%d/' % port,
io_loop=self.io_loop,
connect_timeout=3600)
- self.assertEqual(cm.exception.code, 599)
@gen_test
def test_websocket_close_buffered_data(self):