diff --git a/stream/forwarding/forwarding.go b/stream/forwarding/forwarding.go
index c6fdf9b..e32316f 100644
--- a/stream/forwarding/forwarding.go
+++ b/stream/forwarding/forwarding.go
@@ -18,7 +18,9 @@ type Options map[string][]string
 func Serve(inputChannel chan srt.Packet, cfg Options) {
 	if len(cfg) < 1 {
 		// No forwarding, ignore
-		return
+		for {
+			<-inputChannel // Clear input channel
+		}
 	}
 
 	log.Printf("Stream forwarding initialized")