diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
index 908e45c2..bd9fd30a 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
@@ -82,8 +82,8 @@ class EncodedStreams : ISequentialMessageEvent {
             return
         }
 
-        if (result.values.all { it?.status?.statusType == StatusType.SUCCESS }) {
-
+        if (result.values.any { it?.status?.statusType != StatusType.SUCCESS }) {
+            produceErrorMessage(Message(referenceId = referenceId, status = Status(statusType = StatusType.ERROR)), "Failed messages found!")
             return
         }
         val fileResult = baseMessage.data as FileWatcher.FileResult?