v0.0.633

2026-04-13 16:12:09 +02:00
parent 1edc2712ed
commit f62e7499ec
4 changed files with 52 additions and 20 deletions
@@ -173,14 +173,14 @@ func (ps *PubSub[TNamespace, TData]) PublishAsync(ns TNamespace, data TData, tim
 	subscriber = len(subs)

 	for _, sub := range subs {
-		func() {
+		go func() {
 			sub.subLock.Lock()
 			defer sub.subLock.Unlock()

 			if sub.Func != nil {
 				go func() { sub.Func(data) }()
 			} else if sub.Chan != nil {
-				go func() { _ = syncext.WriteChannelWithTimeout(sub.Chan, data, timeout) }()
+				_ = syncext.WriteChannelWithTimeout(sub.Chan, data, timeout)
 			}
 		}()
 	}