(self, loop, sock, protocol, waiter=None,
extra=None, server=None, buffer_size=65536)
| 183 | """Transport for read pipes.""" |
| 184 | |
| 185 | def __init__(self, loop, sock, protocol, waiter=None, |
| 186 | extra=None, server=None, buffer_size=65536): |
| 187 | self._pending_data_length = -1 |
| 188 | self._paused = True |
| 189 | super().__init__(loop, sock, protocol, waiter, extra, server) |
| 190 | |
| 191 | self._data = bytearray(buffer_size) |
| 192 | self._loop.call_soon(self._loop_reading) |
| 193 | self._paused = False |
| 194 | |
| 195 | def is_reading(self): |
| 196 | return not self._paused and not self._closing |