(self, transp)
| 206 | |
| 207 | class _SendfileFallbackProtocol(protocols.Protocol): |
| 208 | def __init__(self, transp): |
| 209 | if not isinstance(transp, transports._FlowControlMixin): |
| 210 | raise TypeError("transport should be _FlowControlMixin instance") |
| 211 | self._transport = transp |
| 212 | self._proto = transp.get_protocol() |
| 213 | self._should_resume_reading = transp.is_reading() |
| 214 | self._should_resume_writing = transp._protocol_paused |
| 215 | transp.pause_reading() |
| 216 | transp.set_protocol(self) |
| 217 | if self._should_resume_writing: |
| 218 | self._write_ready_fut = self._transport._loop.create_future() |
| 219 | else: |
| 220 | self._write_ready_fut = None |
| 221 | |
| 222 | async def drain(self): |
| 223 | if self._transport.is_closing(): |
nothing calls this directly
no test coverage detected