Handle a single h2 event. Args: event: h2 event object Returns: HTTP2Request if a request is complete, None otherwise
(self, event)
| 192 | return completed_requests |
| 193 | |
| 194 | def _handle_event(self, event): |
| 195 | """Handle a single h2 event. |
| 196 | |
| 197 | Args: |
| 198 | event: h2 event object |
| 199 | |
| 200 | Returns: |
| 201 | HTTP2Request if a request is complete, None otherwise |
| 202 | """ |
| 203 | if isinstance(event, _h2_events.RequestReceived): |
| 204 | return self._handle_request_received(event) |
| 205 | |
| 206 | elif isinstance(event, _h2_events.DataReceived): |
| 207 | return self._handle_data_received(event) |
| 208 | |
| 209 | elif isinstance(event, _h2_events.StreamEnded): |
| 210 | return self._handle_stream_ended(event) |
| 211 | |
| 212 | elif isinstance(event, _h2_events.StreamReset): |
| 213 | self._handle_stream_reset(event) |
| 214 | |
| 215 | elif isinstance(event, _h2_events.WindowUpdated): |
| 216 | pass # Flow control update, handled by h2 |
| 217 | |
| 218 | elif isinstance(event, _h2_events.PriorityUpdated): |
| 219 | self._handle_priority_updated(event) |
| 220 | |
| 221 | elif isinstance(event, _h2_events.SettingsAcknowledged): |
| 222 | pass # Settings ACK received |
| 223 | |
| 224 | elif isinstance(event, _h2_events.ConnectionTerminated): |
| 225 | self._handle_connection_terminated(event) |
| 226 | |
| 227 | elif isinstance(event, _h2_events.TrailersReceived): |
| 228 | return self._handle_trailers_received(event) |
| 229 | |
| 230 | return None |
| 231 | |
| 232 | def _handle_request_received(self, event): |
| 233 | """Handle RequestReceived event (HEADERS frame).""" |
no test coverage detected