(self, app_protocol)
| 351 | self._get_app_transport() |
| 352 | |
| 353 | def _set_app_protocol(self, app_protocol): |
| 354 | self._app_protocol = app_protocol |
| 355 | # Make fast hasattr check first |
| 356 | if (hasattr(app_protocol, 'get_buffer') and |
| 357 | isinstance(app_protocol, protocols.BufferedProtocol)): |
| 358 | self._app_protocol_get_buffer = app_protocol.get_buffer |
| 359 | self._app_protocol_buffer_updated = app_protocol.buffer_updated |
| 360 | self._app_protocol_is_buffer = True |
| 361 | else: |
| 362 | self._app_protocol_is_buffer = False |
| 363 | |
| 364 | def _wakeup_waiter(self, exc=None): |
| 365 | if self._waiter is None: |
no outgoing calls
no test coverage detected