fix: 等待track的时候,由于没有使用指针导致修改状态没有生效

This commit is contained in:
dexter
2022-12-11 15:12:13 +08:00
parent 3e1796f148
commit a090919b39

View File

@@ -394,7 +394,7 @@ func (w *waitTracks) Accept(t Track) bool {
// 流状态处理中枢,包括接收订阅发布指令等
func (s *Stream) run() {
waitP := make(map[ISubscriber]waitTracks)
waitP := make(map[ISubscriber]*waitTracks)
for {
select {
case <-s.timeout.C:
@@ -510,7 +510,7 @@ func (s *Stream) run() {
})
}
if waits.NeedWait() {
waitP[suber] = waits
waitP[suber] = &waits
} else {
v.Resolve(util.Null)
}