|
|
@ -402,8 +402,8 @@ func (s *Stream) closeInter() { |
|
|
|
s.ws.Range(func(key, val interface{}) bool { |
|
|
|
s.ws.Range(func(key, val interface{}) bool { |
|
|
|
v := val.(*PackWriterCloser) |
|
|
|
v := val.(*PackWriterCloser) |
|
|
|
if v.w != nil { |
|
|
|
if v.w != nil { |
|
|
|
if v.w.Info().IsInterval() { |
|
|
|
|
|
|
|
v.w.Close(fmt.Errorf("closed")) |
|
|
|
v.w.Close(fmt.Errorf("closed")) |
|
|
|
|
|
|
|
if v.w.Info().IsInterval() { |
|
|
|
s.ws.Delete(key) |
|
|
|
s.ws.Delete(key) |
|
|
|
log.Debugf("[%v] player closed and remove\n", v.w.Info()) |
|
|
|
log.Debugf("[%v] player closed and remove\n", v.w.Info()) |
|
|
|
} |
|
|
|
} |
|
|
|