Fix for completion

This commit is contained in:
Brage 2023-07-20 01:05:13 +02:00
parent 2a375c317a
commit 3a837cef0c

View File

@ -82,8 +82,8 @@ class EncodedStreams : ISequentialMessageEvent {
return 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 return
} }
val fileResult = baseMessage.data as FileWatcher.FileResult? val fileResult = baseMessage.data as FileWatcher.FileResult?