如何在asyncio和transport_base类中创建python并行套接字？

import asyncio
from asyncio.transports import transport_base

class ParallelSocketTransport(transport_base.Transport):
    def __init__(self):
        # 初始化操作

    def write(self, data):
        # 发送数据的逻辑

    def close(self):
        # 关闭连接的逻辑

    # 其他方法的实现

async def handle_connection(reader, writer):
    # 处理连接的逻辑

    transport = ParallelSocketTransport()
    transport.write(data)
    transport.close()

async def start_server():
    server = await asyncio.start_server(
        handle_connection, 'localhost', 8888)
    addr = server.sockets[0].getsockname()
    print(f'Serving on {addr}')

    async with server:
        await server.serve_forever()

if __name__ == '__main__':
    asyncio.run(start_server())