TyleoDvDelaware3217/GoDoxy
1
0
Fork 0
mirror of https://github.com/yusing/godoxy.git synced 2025-06-04 02:42:34 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

fix(routes): accidentally finished all routes when one route changed

Browse source
This commit is contained in:
yusing 2025-05-29 19:22:42 +08:00
parent 371e756307
commit ed07bf42ce
2 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
internal/route/provider/provider.go
View file

@ -110,8 +110,6 @@ func (p *Provider) Start(parent task.Parent) gperr.Error {
t.Subtask("event_queue", false), t.Subtask("event_queue", false),
providerEventFlushInterval, providerEventFlushInterval,
func(events []events.Event) { func(events []events.Event) {
routesTask.FinishAndWait("reload routes")
routesTask = t.Subtask("routes", false)
handler := p.newEventHandler() handler := p.newEventHandler()
// routes' lifetime should follow the provider's lifetime // routes' lifetime should follow the provider's lifetime
handler.Handle(routesTask, events) handler.Handle(routesTask, events)

2
internal/route/route.go
View file

@ -227,7 +227,7 @@ func (r *Route) Finish(reason any) {
if r.impl == nil { if r.impl == nil {
return return
} }
r.impl.Finish(reason) r.impl.Task().FinishAndWait(reason)
r.impl = nil r.impl = nil
} }