(self, stream_id, headers, is_end=False)
| 213 | self._send_wakeup.send(b"\x01") |
| 214 | |
| 215 | def send_headers(self, stream_id, headers, is_end=False): |
| 216 | with self._lock: |
| 217 | super().send_headers(stream_id, headers, is_end) |
| 218 | if is_end: |
| 219 | self._send_wakeup.send(b"\x01") |
| 220 | |
| 221 | def send_data(self, stream_id, data, is_end=False): |
| 222 | with self._lock: |