fix tests
This commit is contained in:
parent
780970dc54
commit
7acf410d21
|
@ -559,12 +559,16 @@ class SelectorSocketTransportTests(test_utils.TestCase):
|
||||||
tr.pause_reading()
|
tr.pause_reading()
|
||||||
test_utils.run_briefly(self.loop)
|
test_utils.run_briefly(self.loop)
|
||||||
self.assertFalse(tr.is_reading())
|
self.assertFalse(tr.is_reading())
|
||||||
self.loop.assert_no_reader(7, tr._read_ready)
|
self.loop.assert_no_reader(7)
|
||||||
|
|
||||||
tr.resume_reading()
|
tr.resume_reading()
|
||||||
self.assertTrue(tr.is_reading())
|
self.assertTrue(tr.is_reading())
|
||||||
self.loop.assert_reader(7, tr._read_ready)
|
self.loop.assert_reader(7, tr._read_ready)
|
||||||
|
|
||||||
|
tr.close()
|
||||||
|
self.assertFalse(tr.is_reading())
|
||||||
|
self.loop.assert_no_reader(7)
|
||||||
|
|
||||||
|
|
||||||
def test_read_eof_received_error(self):
|
def test_read_eof_received_error(self):
|
||||||
transport = self.socket_transport()
|
transport = self.socket_transport()
|
||||||
|
|
Loading…
Reference in New Issue