Lines Matching refs:transport
13 transport = asyncio.Transport()
14 self.assertEqual(transport._extra, {})
17 transport = asyncio.Transport({'extra': 'info'})
18 self.assertEqual('info', transport.get_extra_info('extra'))
19 self.assertIsNone(transport.get_extra_info('unknown'))
22 self.assertIs(default, transport.get_extra_info('unknown', default))
25 transport = asyncio.Transport()
26 transport.write = mock.Mock()
28 transport.writelines([b'line1',
31 self.assertEqual(1, transport.write.call_count)
32 transport.write.assert_called_with(b'line1line2line3')
35 transport = asyncio.Transport()
38 transport.set_write_buffer_limits)
39 self.assertRaises(NotImplementedError, transport.get_write_buffer_size)
40 self.assertRaises(NotImplementedError, transport.write, 'data')
41 self.assertRaises(NotImplementedError, transport.write_eof)
42 self.assertRaises(NotImplementedError, transport.can_write_eof)
43 self.assertRaises(NotImplementedError, transport.pause_reading)
44 self.assertRaises(NotImplementedError, transport.resume_reading)
45 self.assertRaises(NotImplementedError, transport.close)
46 self.assertRaises(NotImplementedError, transport.abort)
49 transport = asyncio.DatagramTransport()
51 self.assertRaises(NotImplementedError, transport.sendto, 'data')
52 self.assertRaises(NotImplementedError, transport.abort)
55 transport = asyncio.SubprocessTransport()
57 self.assertRaises(NotImplementedError, transport.get_pid)
58 self.assertRaises(NotImplementedError, transport.get_returncode)
59 self.assertRaises(NotImplementedError, transport.get_pipe_transport, 1)
60 self.assertRaises(NotImplementedError, transport.send_signal, 1)
61 self.assertRaises(NotImplementedError, transport.terminate)
62 self.assertRaises(NotImplementedError, transport.kill)
67 transports.Transport):
73 transport = MyTransport(loop=loop)
74 transport._protocol = mock.Mock()
76 self.assertFalse(transport._protocol_paused)
79 transport.set_write_buffer_limits(high=0, low=1)
81 transport.set_write_buffer_limits(high=1024, low=128)
82 self.assertFalse(transport._protocol_paused)
83 self.assertEqual(transport.get_write_buffer_limits(), (128, 1024))
85 transport.set_write_buffer_limits(high=256, low=128)
86 self.assertTrue(transport._protocol_paused)
87 self.assertEqual(transport.get_write_buffer_limits(), (128, 256))
