Fix empty streams json on stream lock

This commit is contained in:
Alexey Khit
2023-01-13 13:37:36 +03:00
parent ba0c7d911d
commit dba0989c54

View File

@@ -198,8 +198,12 @@ producers:
//} //}
func (s *Stream) MarshalJSON() ([]byte, error) { func (s *Stream) MarshalJSON() ([]byte, error) {
if !s.mu.TryLock() {
log.Warn().Msgf("[streams] json locked")
return []byte(`null`), nil
}
var v []interface{} var v []interface{}
s.mu.Lock()
for _, prod := range s.producers { for _, prod := range s.producers {
if prod.element != nil { if prod.element != nil {
v = append(v, prod.element) v = append(v, prod.element)