/external/python/cpython3/Lib/asyncio/ |
transports.py | 92 def get_write_buffer_size(self): member in class:WriteTransport 236 The subclass must implement get_write_buffer_size(). It must call 246 get_write_buffer_size(), and their protocol's pause_writing() and 258 size = self.get_write_buffer_size() 275 self.get_write_buffer_size() <= self._low_water): 310 def get_write_buffer_size(self): member in class:_FlowControlMixin
|
sslproto.py | 368 def get_write_buffer_size(self): member in class:_SSLProtocolTransport 370 return self._ssl_protocol._transport.get_write_buffer_size()
|
selector_events.py | 625 bufsize = self.get_write_buffer_size() 698 def get_write_buffer_size(self): member in class:_SelectorTransport 947 def get_write_buffer_size(self): member in class:_SelectorDatagramTransport [all...] |
unix_events.py | 604 bufsize = self.get_write_buffer_size() 612 def get_write_buffer_size(self): member in class:_UnixWritePipeTransport [all...] |
proactor_events.py | 149 def get_write_buffer_size(self): member in class:_ProactorBasePipeTransport
|
/external/python/cpython3/Lib/test/test_asyncio/ |
test_transports.py | 39 self.assertRaises(NotImplementedError, transport.get_write_buffer_size) 70 def get_write_buffer_size(self): member in class:TransportTests.test_flowcontrol_mixin_set_write_limits.MyTransport
|
test_proactor_events.py | 396 self.assertEqual(tr.get_write_buffer_size(), 0) 414 self.assertEqual(tr.get_write_buffer_size(), 0) 425 self.assertEqual(tr.get_write_buffer_size(), 3) 431 self.assertEqual(tr.get_write_buffer_size(), 6) 442 self.assertEqual(tr.get_write_buffer_size(), 1) 448 self.assertEqual(tr.get_write_buffer_size(), 3) 454 self.assertEqual(tr.get_write_buffer_size(), 6) 467 self.assertEqual(tr.get_write_buffer_size(), 0) [all...] |