zhaojiajun193

关于protocol/rmtp/stream.go下的TransStart()函数的问题

1

s.ws.Range(func(key, val interface{}) bool { v := val.(*PackWriterCloser) fmt.Printf(key.(string) + "\n") if !v.init { if err = s.cache.Send(v.w); err != nil { log.Debugf("[%s] send cache packet error: %v, remove", v.w.Info(),...

s.ws.Range(func(key, val interface{}) bool { v := val.(*PackWriterCloser) fmt.Printf(key.(string) + "\n") if !v.init { if err = s.cache.Send(v.w); err != nil { log.Debugf("[%s] send cache packet error: %v, remove", v.w.Info(),...