带有自定义连接器的 AIOHTTP 在请求时挂起

问：

我有一个名为 with 方法的类来处理我自己的数据流，主要是： .他们确实工作并正确控制任何请求。
我尝试将其用作自定义连接器，以便用户可以执行以下操作：Channelread(), write(), open(), end(), close(), incoming/outcoming_queue

        async with aiohttp.ClientSession(connector=self.custom_connector) as session:
            async with session.get(url) as resp:
                return await resp.text())

它会让我custom_connector处理请求的目标。

class CustomConnector(aiohttp.BaseConnector):
    async def _create_connection(self, req, traces, timeout):
        # duplex_channel is an instance of the Channel class (described above).
        return duplex_channel

但目前，代码挂在行上。我相信这是因为我的 Channel 类不是 aiohttp 所期望的。文档提到了，但它并没有真正深入挖掘任何地方。从 '_create_connection（）' 方法返回的对象应该实现哪些方法？我可能在这里遗漏了什么？session.get(url)ResponseHandler