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 22175f78..35aab391 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 @@ -66,8 +66,12 @@ class EncodedStreams : ISequentialMessageEvent { override fun areAllMessagesPresent(currentEvents: List): Boolean { val expected = listOf(KnownEvents.EVENT_READER_RECEIVED_FILE.event, KnownEvents.EVENT_READER_RECEIVED_STREAMS.event) val waitingFor = expected.filter { !currentEvents.contains(it) } - logger.info { "Waiting for events: \n ${waitingFor.joinToString("\n\t")}" } - return expected.containsAll(currentEvents) + return if (waitingFor.isEmpty()) { + true + } else { + logger.info { "Waiting for events: \n ${waitingFor.joinToString("\n\t")}" } + false + } } override fun onAllMessagesProcessed(referenceId: String, result: Map) {