Fix polling of buffered scrobbles

navidrome · Feb 8, 2023 · a3b8682 · a3b8682
1 parent 0bbb549
commit a3b8682
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/scrobbler/buffered_scrobbler.go b/core/scrobbler/buffered_scrobbler.go
@@ -7,7 +7,6 @@ import (
 
 	"github.com/navidrome/navidrome/log"
 	"github.com/navidrome/navidrome/model"
-	"github.com/navidrome/navidrome/utils/pl"
 )
 
 func newBufferedScrobbler(ds model.DataStore, s Scrobbler, service string) *bufferedScrobbler {
@@ -57,7 +56,12 @@ func (b *bufferedScrobbler) run(ctx context.Context) {
 				b.sendWakeSignal()
 			})
 		}
-		<-pl.ReadOrDone(ctx, b.wakeSignal)
+		select {
+		case <-b.wakeSignal:
+			continue
+		case <-ctx.Done():
+			return
+		}
 	}
 }