From 3a837cef0cf4ec666ee6281912dec5aa70c0b7c3 Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Thu, 20 Jul 2023 01:05:13 +0200
Subject: [PATCH] Fix for completion

---
 .../iktdev/streamit/content/reader/analyzer/EncodedStreams.kt | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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?