third-party-mirrors/navidrome
1
0
Fork 0
mirror of https://github.com/navidrome/navidrome.git synced 2025-04-28 17:32:22 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix polling of buffered scrobbles

Browse Source
This commit is contained in:
Deluan 2023-02-07 19:17:50 -05:00
parent 0bbb54934b
commit a3b8682d44
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core/scrobbler/buffered_scrobbler.go
View File

@ -7,7 +7,6 @@ import (
"github.com/navidrome/navidrome/log" "github.com/navidrome/navidrome/log"
"github.com/navidrome/navidrome/model" "github.com/navidrome/navidrome/model"
"github.com/navidrome/navidrome/utils/pl"
) )
func newBufferedScrobbler(ds model.DataStore, s Scrobbler, service string) *bufferedScrobbler { func newBufferedScrobbler(ds model.DataStore, s Scrobbler, service string) *bufferedScrobbler {
@ -57,7 +56,12 @@ func (b *bufferedScrobbler) run(ctx context.Context) {
b.sendWakeSignal() b.sendWakeSignal()
}) })
} }
<-pl.ReadOrDone(ctx, b.wakeSignal) select {
case <-b.wakeSignal:
continue
case <-ctx.Done():
return
}
} }
} }