(self, event_list)
| 742 | self._transports[transp._sock_fd] = transp |
| 743 | |
| 744 | def _process_events(self, event_list): |
| 745 | for key, mask in event_list: |
| 746 | fileobj, (reader, writer) = key.fileobj, key.data |
| 747 | if mask & selectors.EVENT_READ and reader is not None: |
| 748 | if reader._cancelled: |
| 749 | self._remove_reader(fileobj) |
| 750 | else: |
| 751 | self._add_callback(reader) |
| 752 | if mask & selectors.EVENT_WRITE and writer is not None: |
| 753 | if writer._cancelled: |
| 754 | self._remove_writer(fileobj) |
| 755 | else: |
| 756 | self._add_callback(writer) |
| 757 | |
| 758 | def _stop_serving(self, sock): |
| 759 | self._remove_reader(sock.fileno()) |
nothing calls this directly
no test coverage detected