(self, protocol)
| 962 | self._call_soon(futures._set_result_unless_cancelled, waiter, None) |
| 963 | |
| 964 | def set_protocol(self, protocol): |
| 965 | if isinstance(protocol, protocols.BufferedProtocol): |
| 966 | self._read_ready_cb = self._read_ready__get_buffer |
| 967 | else: |
| 968 | self._read_ready_cb = self._read_ready__data_received |
| 969 | |
| 970 | super().set_protocol(protocol) |
| 971 | |
| 972 | def _read_ready(self): |
| 973 | self._read_ready_cb() |
nothing calls this directly
no test coverage detected