diff --git a/internal/utils/stream/stream.go b/internal/utils/stream/stream.go
index ef29a9e41..5b39797df 100644
--- a/internal/utils/stream/stream.go
+++ b/internal/utils/stream/stream.go
@@ -182,9 +182,12 @@ func (r *Stream[T]) Close() {
 		return
 	}
 
+	// fixed:issues #292 fatal error: concurrent map iteration and map write
+	r.l.Lock()
 	for _, f := range r.beforeClose {
 		f()
 	}
+	r.l.Unlock()
 
 	select {
 	case r.sig <- false: