mirror of
https://github.com/MontFerret/ferret.git
synced 2025-08-13 19:52:52 +02:00
Removed unneccessary goroutine
This commit is contained in:
@@ -7,6 +7,4 @@ NAVIGATE(doc, "https://github.com/features")
|
||||
LET features = ELEMENT(doc, '.application-main')
|
||||
LET featuresTxt = features.innerText
|
||||
|
||||
LOG("featuresTxt:", featuresTxt)
|
||||
|
||||
RETURN mainTxt == featuresTxt
|
||||
RETURN mainTxt != featuresTxt
|
||||
|
@@ -258,7 +258,6 @@ func (broker *EventBroker) emit(ctx context.Context, event Event, message interf
|
||||
}
|
||||
|
||||
broker.mu.Lock()
|
||||
defer broker.mu.Unlock()
|
||||
|
||||
listeners, ok := broker.listeners[event]
|
||||
|
||||
@@ -269,14 +268,14 @@ func (broker *EventBroker) emit(ctx context.Context, event Event, message interf
|
||||
snapshot := make([]EventListener, len(listeners))
|
||||
copy(snapshot, listeners)
|
||||
|
||||
go func() {
|
||||
for _, listener := range snapshot {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
return
|
||||
default:
|
||||
listener(message)
|
||||
}
|
||||
broker.mu.Unlock()
|
||||
|
||||
for _, listener := range snapshot {
|
||||
select {
|
||||
case <-ctx.Done():
|
||||
return
|
||||
default:
|
||||
listener(message)
|
||||
}
|
||||
}()
|
||||
}
|
||||
}
|
||||
|
Reference in New Issue
Block a user