更改运输的接收和发送方法

问题描述

我正在尝试使用pysctp套接字实现基于SCTP和基于异步的客户端。理想情况下,我想做类似的事情:

async def sctp_client():
    sock = sctp.sctpsocket_udp(socket.AF_INET)
    reader,writer = await asyncio.open_connection(sock=sock)
    writer.write(b'some data',ppid=5)
    await writer.drain()
    data = await reader.read(100)
    print(f'Received: {data.decode()}')
    writer.close()
    await writer.wait_closed()

实际上,有两个问题:

  • 是否可以将“运输工厂”传递给open_connectionloop.create_connection 我希望流包含的传输对象使用sctp_recv而不是recvsctp_send而不是send。显然,最简单的方法是从原始传输类派生,但是我找不到一种很好的pythonic方法来实现它。
  • 是否可以从StreamWriter获取自定义open_connection显然,我可以从原始文件中创建自己的文件,可以在原始文件中添加方法,也可以只访问内部运输,但这些选择非常难看。我能想到的第二个最佳方法就是使用open_connection实现自己的loop.create_connection

非常感谢!

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)