zishuo/eventbus2
1
0
Fork 0
mirror of https://github.com/werbenhu/eventbus.git synced 2025-09-26 20:41:48 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove second goroutine for channel loop in Publish and PublishSync methods

Browse Source
This commit is contained in:
Nandor Kracser
2025-09-04 12:47:26 +02:00
parent d779b39f70
commit ff6e1e41b5
1 changed files with 0 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
eventbus.go
View File

@@ -209,7 +209,6 @@ func (e *EventBus) Publish(topic string, payload any) error {
if !ok {
ch = newChannel(topic, e.bufferSize)
e.channels.Store(topic, ch)
go ch.(*channel).loop()
}
return ch.(*channel).publish(payload)
@@ -224,7 +223,6 @@ func (e *EventBus) PublishSync(topic string, payload any) error {
if !ok {
ch = newChannel(topic, e.bufferSize)
e.channels.Store(topic, ch)
go ch.(*channel).loop()
}
return ch.(*channel).publishSync(payload)