Lines Matching refs:protocol
32 self.protocol = test_utils.make_test_protocol(asyncio.Protocol)
37 self.protocol, waiter=waiter)
46 self.protocol.connection_made(tr)
53 self.assertFalse(self.protocol.data_received.called)
54 self.assertFalse(self.protocol.eof_received.called)
64 self.protocol.data_received.assert_called_with(b'data')
77 self.assertTrue(self.protocol.eof_received.called)
195 self.protocol.connection_lost.assert_called_with(None)
207 self.protocol.connection_lost.assert_called_with(None)
211 self.protocol.connection_lost.reset_mock()
214 self.assertFalse(self.protocol.connection_lost.called)
221 self.assertFalse(self.protocol.connection_lost.called)
228 self.assertFalse(self.protocol.connection_lost.called)
248 self.protocol.connection_lost.assert_called_with(None)
257 self.assertFalse(self.protocol.connection_lost.called)
265 self.protocol.connection_lost.assert_called_with(None)
271 self.assertTrue(self.protocol.connection_lost.called)
299 self.loop, self.sock, self.protocol)
308 tr = _ProactorWritePipeTransport(self.loop, self.sock, self.protocol)
324 self.loop, self.sock, self.protocol)
341 self.protocol.data_received.assert_called_with(b'data1')
343 self.protocol.data_received.assert_called_with(b'data2')
348 self.protocol.data_received.assert_called_with(b'data2')
352 self.protocol.data_received.assert_called_with(b'data3')
354 self.protocol.data_received.assert_called_with(b'data4')
363 self.assertFalse(self.protocol.pause_writing.called)
364 self.assertFalse(self.protocol.resume_writing.called)
375 self.assertTrue(self.protocol.pause_writing.called)
381 self.assertTrue(self.protocol.resume_writing.called)
392 self.assertFalse(self.protocol.pause_writing.called)
398 self.assertTrue(self.protocol.pause_writing.called)
409 self.assertFalse(self.protocol.pause_writing.called)
415 self.assertFalse(self.protocol.pause_writing.called)
421 self.assertTrue(self.protocol.pause_writing.called)
434 self.assertFalse(self.protocol.pause_writing.called)
513 tr = self.loop._make_socket_transport(self.sock, asyncio.Protocol())
