diff --git a/cmd/livesim2/app/cmaf-ingester.go b/cmd/livesim2/app/cmaf-ingester.go
index 43f1b37..8cf9e3c 100644
--- a/cmd/livesim2/app/cmaf-ingester.go
+++ b/cmd/livesim2/app/cmaf-ingester.go
@@ -683,6 +683,7 @@ func (cs *cmafSource) Write(b []byte) (int, error) {
 		if nrWritten == len(b) {
 			break
 		}
+		<-cs.writeMoreCh
 	}
 	return len(b), nil
 }