running coroutine from quic_event_received

[mdierksen]

First, thanks to the authors for this nice library.

I am currently playing around with it and managed to implement QUIC in an application as an alternative to TCP with TLS using the standard asyncio.start_server and asyncio.open_connection. Everything seems to work fine.

I had some issues figuring out how to run a corouting to process the received data from within the quic_event_received function.

What seems to work is something like this:

async def process_data(_):
    return b"42"

class CustomQuicProtocol(QuicConnectionProtocol):
   def send_result(self, stream_id, result):
        self._quic.send_stream_data(stream_id, result, end_stream=True)
        self.transmit()

    def quic_event_received(self, event):
        if isinstance(event, StreamDataReceived):
            asyncio.create_task(process_data(event.data)).add_done_callback(lambda task: self.send_result(event.stream_id, task.result()))

The self.transmit() turned out to be necessary depending on what the actual data processing code was.

Is there a better way to do this? Would it be possible to change the quic_event_received function to a coroutine so one could simply use await?