gnblao
gnblao
### **py测试工具** 留个简单记录 py_cli: ``` #!/usr/bin/env python #coding=utf-8 import asyncio import websockets import sys # 向服务器端发送认证后的消息 async def send_msg(websocket): while True: _text = input("please enter your context: ") if _text...
> 对于chanel send one操作，如果数据很大，需要异步写。你现在的逻辑正确吗？我原来的做法是dup一个fd。 嗯，现在想法还是保持poller一致，fd在异步同一时间只能读，或只能写。不过还是保持写优先 在channel中有个写的list，在异步写回调中检查list是否为空，不为空就继续写。 chanel send one中在触发sync的情况下要连续发送list中数据，直到触发async或list为空就返回。 上面的设想，会在极端情况下会造成read延时，不过现阶段还不用考虑，后续的话在考虑是用dup，还是改poller同时支持读写来优化吧
> 好家伙！我直呼好家伙！ > > 我是说楼主的头像。。。 🤣🤣🤣🤦
> @gnblao 麻烦打开一下你项目的issue啊。 哈哈，之前没注意，原以为是默认开着的～～
大佬，关于channel功能，基本开发完了。我有想法推到你们仓库，不然在我那边基本没人用了哈～抽空帮忙review下，看看是否合适～～
> > 大佬，关于channel功能，基本开发完了。我有想法推到你们仓库，不然在我那边基本没人用了哈～抽空帮忙review下，看看是否合适～～ > > 我可以review，也可以想办法帮你宣传。但是这个代码合进来不太现实啊，我们主分支尽量只保持必要的功能（我自己都拒绝了自己的一个channel修改）。作为一个增强功能的fork，也是很符合github的玩法的。 了解，主分支尽量简洁～～
> > > > 大佬，关于channel功能，基本开发完了。我有想法推到你们仓库，不然在我那边基本没人用了哈～抽空帮忙review下，看看是否合适～～ > > > > > > > > > 我可以review，也可以想办法帮你宣传。但是这个代码合进来不太现实啊，我们主分支尽量只保持必要的功能（我自己都拒绝了自己的一个channel修改）。作为一个增强功能的fork，也是很符合github的玩法的。 > > > > 了解，主分支尽量简洁～～ > > 实在是很不好意思啊，到时候我在主页上加个显眼的链接到你那边吧，有这个需求的用户肯定会使用的。 大佬创新设计一个架构不容易，我从中也白嫖了不少好东西，继续大佬学习，哈哈哈～
> 请问这方面有考虑过吗， 我自己测试了下， 断开server端后stream cli就没有重连动作。 这个功能没有支持，还没来得及实现 :-)