(self, ov, maxsize)
| 363 | return bool(wait([self], timeout)) |
| 364 | |
| 365 | def _get_more_data(self, ov, maxsize): |
| 366 | buf = ov.getbuffer() |
| 367 | f = io.BytesIO() |
| 368 | f.write(buf) |
| 369 | left = _winapi.PeekNamedPipe(self._handle)[1] |
| 370 | assert left > 0 |
| 371 | if maxsize is not None and len(buf) + left > maxsize: |
| 372 | self._bad_message_length() |
| 373 | ov, err = _winapi.ReadFile(self._handle, left, overlapped=True) |
| 374 | rbytes, err = ov.GetOverlappedResult(True) |
| 375 | assert err == 0 |
| 376 | assert rbytes == left |
| 377 | f.write(ov.getbuffer()) |
| 378 | return f |
| 379 | |
| 380 | |
| 381 | class Connection(_ConnectionBase): |
no test coverage detected