diff --git a/internal/hls/client_video_processor.go b/internal/hls/client_video_processor.go
index 2b3f9ad8..a6779f62 100644
--- a/internal/hls/client_video_processor.go
+++ b/internal/hls/client_video_processor.go
@@ -137,7 +137,10 @@ func (p *clientVideoProcessor) process(
 	data []byte,
 	pts time.Duration,
 	dts time.Duration) {
-	p.queue <- clientVideoProcessorData{data, pts, dts}
+	select {
+	case p.queue <- clientVideoProcessorData{data, pts, dts}:
+	case <-p.ctx.Done():
+	}
 }
 
 func (p *clientVideoProcessor) initializeTrack() error {