fix: wait for dispatch goroutine to finish (#780)

* wait for dispatch goroutine to finish * move the wait into write function
dunglas · Jun 4, 2023 · f858af1 · f858af1
1 parent 9f28716
commit f858af1
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/subscribe.go b/subscribe.go
@@ -222,6 +222,8 @@ func (h *Hub) write(w io.Writer, s zapcore.ObjectMarshaler, data string) bool {
 			c.Write(zap.Object("subscriber", s))
 		}
 
+		// wait for the dispatch goroutine to finish
+		<-done
 		return false
 	}
 }