diff --git a/cmd/streams/stream.go b/cmd/streams/stream.go
index 0e2d5d43..3f60ad37 100644
--- a/cmd/streams/stream.go
+++ b/cmd/streams/stream.go
@@ -185,6 +185,11 @@ producers:
 				continue producers
 			}
 		}
+		for _, track := range producer.senders {
+			if len(track.Senders()) > 0 {
+				continue producers
+			}
+		}
 		producer.stop()
 	}
 	s.mu.Unlock()