(self, timeout: float = 0)
| 153 | self.encoder = None |
| 154 | |
| 155 | def can_read(self, timeout: float = 0) -> bool: |
| 156 | # TODO: Rename this API; it detects pending data or dirty/closed |
| 157 | # connection state, not only whether application data can be read. |
| 158 | if self._buffer is None: |
| 159 | return False |
| 160 | return self._buffer.can_read(timeout) |
| 161 | |
| 162 | |
| 163 | class AsyncBaseParser(BaseParser): |