Closed Detxie closed 3 months ago
一、问题描述: 1.在使用engine时,推的流在engine/subscriber.go里面报stop xxx ,错误的原因为error dsicard; 2.看了下discard在engine/common/frame.go中,有注释--如果写入时还有读取者没有离开则废弃该帧。防止并发读写。
二、疑问 1.之前的流错误都是timeout等,会走hook插件。但是这个错误并没有。 2.关于discard()方法的解释还能有更加全局,详细一点的解析么。plz
https://mp.weixin.qq.com/s?__biz=MzkyMDQ5Nzg5MQ==&mid=2247483819&idx=1&sn=188dee78a12ca3d0f28196b2b641519a&chksm=c190ba27f6e73331348848eb84e213b2d49d2e4030bc074c4ea3af7c890f12b0d05f469cf597&scene=178&cur_album_id=2979318380627460104#rd
这个不属于流错误,单纯是由于订阅者消费卡住引起的,因此这里会终止订阅者
thx
一、问题描述: 1.在使用engine时,推的流在engine/subscriber.go里面报stop xxx ,错误的原因为error dsicard; 2.看了下discard在engine/common/frame.go中,有注释--如果写入时还有读取者没有离开则废弃该帧。防止并发读写。
二、疑问 1.之前的流错误都是timeout等,会走hook插件。但是这个错误并没有。 2.关于discard()方法的解释还能有更加全局,详细一点的解析么。plz