_core, test_websocket: Remove unused locals

This commit is contained in:
Allan Lewis
2016-04-27 11:51:59 +01:00
parent 3b757ac3e2
commit a9cfa61dc3
2 changed files with 8 additions and 8 deletions

View File

@@ -79,7 +79,7 @@ class WebSocket(object):
def __init__(self, get_mask_key=None, sockopt=None, sslopt=None, def __init__(self, get_mask_key=None, sockopt=None, sslopt=None,
fire_cont_frame=False, enable_multithread=False, fire_cont_frame=False, enable_multithread=False,
skip_utf8_validation=False, **options): skip_utf8_validation=False, **_):
""" """
Initialize WebSocket object. Initialize WebSocket object.
""" """

View File

@@ -44,7 +44,7 @@ TEST_SECURE_WS = True
TRACEABLE = False TRACEABLE = False
def create_mask_key(n): def create_mask_key(_):
return "abcd" return "abcd"
@@ -261,7 +261,7 @@ class WebSocketTest(unittest.TestCase):
@unittest.skipUnless(TEST_WITH_INTERNET, "Internet-requiring tests are disabled") @unittest.skipUnless(TEST_WITH_INTERNET, "Internet-requiring tests are disabled")
def testIter(self): def testIter(self):
count = 2 count = 2
for rsvp in ws.create_connection('ws://stream.meetup.com/2/rsvps'): for _ in ws.create_connection('ws://stream.meetup.com/2/rsvps'):
count -= 1 count -= 1
if count == 0: if count == 0:
break break
@@ -280,7 +280,7 @@ class WebSocketTest(unittest.TestCase):
# s.add_packet(SSLError("The read operation timed out")) # s.add_packet(SSLError("The read operation timed out"))
s.add_packet(six.b("baz")) s.add_packet(six.b("baz"))
with self.assertRaises(ws.WebSocketTimeoutException): with self.assertRaises(ws.WebSocketTimeoutException):
data = sock.frame_buffer.recv_strict(9) sock.frame_buffer.recv_strict(9)
# if six.PY2: # if six.PY2:
# with self.assertRaises(ws.WebSocketTimeoutException): # with self.assertRaises(ws.WebSocketTimeoutException):
# data = sock._recv_strict(9) # data = sock._recv_strict(9)
@@ -290,7 +290,7 @@ class WebSocketTest(unittest.TestCase):
data = sock.frame_buffer.recv_strict(9) data = sock.frame_buffer.recv_strict(9)
self.assertEqual(data, six.b("foobarbaz")) self.assertEqual(data, six.b("foobarbaz"))
with self.assertRaises(ws.WebSocketConnectionClosedException): with self.assertRaises(ws.WebSocketConnectionClosedException):
data = sock.frame_buffer.recv_strict(1) sock.frame_buffer.recv_strict(1)
def testRecvTimeout(self): def testRecvTimeout(self):
sock = ws.WebSocket() sock = ws.WebSocket()
@@ -301,13 +301,13 @@ class WebSocketTest(unittest.TestCase):
s.add_packet(socket.timeout()) s.add_packet(socket.timeout())
s.add_packet(six.b("\x4e\x43\x33\x0e\x10\x0f\x00\x40")) s.add_packet(six.b("\x4e\x43\x33\x0e\x10\x0f\x00\x40"))
with self.assertRaises(ws.WebSocketTimeoutException): with self.assertRaises(ws.WebSocketTimeoutException):
data = sock.recv() sock.recv()
with self.assertRaises(ws.WebSocketTimeoutException): with self.assertRaises(ws.WebSocketTimeoutException):
data = sock.recv() sock.recv()
data = sock.recv() data = sock.recv()
self.assertEqual(data, "Hello, World!") self.assertEqual(data, "Hello, World!")
with self.assertRaises(ws.WebSocketConnectionClosedException): with self.assertRaises(ws.WebSocketConnectionClosedException):
data = sock.recv() sock.recv()
def testRecvWithSimpleFragmentation(self): def testRecvWithSimpleFragmentation(self):
sock = ws.WebSocket() sock = ws.WebSocket()