[asyncio] make quic_event_received public API

aioquic/asyncio/protocol.py

@@ -112,18 +112,9 @@ def datagram_received(self, data: Union[bytes, Text], addr: NetworkAddress) -> N
         self._quic.receive_datagram(cast(bytes, data), addr, now=self._loop.time())
         self._send_pending()
 
-    # private
+    # overridable
 
-    def _create_stream(
-        self, stream_id: int
-    ) -> Tuple[asyncio.StreamReader, asyncio.StreamWriter]:
-        adapter = QuicStreamAdapter(self, stream_id)
-        reader = asyncio.StreamReader()
-        writer = asyncio.StreamWriter(adapter, None, reader, None)
-        self._stream_readers[stream_id] = reader
-        return reader, writer
-
-    def _handle_event(self, event: events.QuicEvent) -> None:
+    def quic_event_received(self, event: events.QuicEvent) -> None:
         if isinstance(event, events.ConnectionIdIssued):
             self._connection_id_issued_handler(event.connection_id)
         elif isinstance(event, events.ConnectionIdRetired):
@@ -149,6 +140,17 @@ def _handle_event(self, event: events.QuicEvent) -> None:
             if event.end_stream:
                 reader.feed_eof()
 
+    # private
+
+    def _create_stream(
+        self, stream_id: int
+    ) -> Tuple[asyncio.StreamReader, asyncio.StreamWriter]:
+        adapter = QuicStreamAdapter(self, stream_id)
+        reader = asyncio.StreamReader()
+        writer = asyncio.StreamWriter(adapter, None, reader, None)
+        self._stream_readers[stream_id] = reader
+        return reader, writer
+
     def _handle_timer(self) -> None:
         now = max(self._timer_at, self._loop.time())
         self._timer = None
@@ -162,7 +164,7 @@ def _send_pending(self) -> None:
         # process events
         event = self._quic.next_event()
         while event is not None:
-            self._handle_event(event)
+            self.quic_event_received(event)
             event = self._quic.next_event()
 
         # send datagrams

examples/http3-client.py

@@ -84,7 +84,7 @@ async def get(self, netloc: str, path: str) -> Deque[Event]:
 
         return await asyncio.shield(waiter)
 
-    def _handle_event(self, event: QuicEvent):
+    def quic_event_received(self, event: QuicEvent):
         #  pass event to the HTTP layer
         for http_event in self._http.handle_event(event):
             if (

examples/http3-server.py

@@ -187,7 +187,7 @@ def __init__(self, quic: QuicConnection, server: HttpServer):
         self._http: Optional[HttpConnection] = None
         self._server = server
 
-    def _handle_event(self, event: QuicEvent):
+    def quic_event_received(self, event: QuicEvent):
         if isinstance(event, aioquic.quic.events.ConnectionTerminated):
             # remove the connection
             for cid, protocol in list(self._server._protocols.items()):