(self, conn, buf, flags=0)
| 537 | return self._register(ov, conn, self.finish_socket_func) |
| 538 | |
| 539 | def send(self, conn, buf, flags=0): |
| 540 | self._register_with_iocp(conn) |
| 541 | ov = _overlapped.Overlapped(NULL) |
| 542 | if isinstance(conn, socket.socket): |
| 543 | ov.WSASend(conn.fileno(), buf, flags) |
| 544 | else: |
| 545 | ov.WriteFile(conn.fileno(), buf) |
| 546 | |
| 547 | return self._register(ov, conn, self.finish_socket_func) |
| 548 | |
| 549 | def accept(self, listener): |
| 550 | self._register_with_iocp(listener) |
no test coverage detected