(self, stream_id, data, is_end=False)
| 219 | self._send_wakeup.send(b"\x01") |
| 220 | |
| 221 | def send_data(self, stream_id, data, is_end=False): |
| 222 | with self._lock: |
| 223 | super().send_data(stream_id, data, is_end) |
| 224 | if is_end: |
| 225 | self._send_wakeup.send(b"\x01") |
| 226 | |
| 227 | def run(self): |
| 228 | if self._closed: |