Adjusted check

This commit is contained in:
Brage 2023-07-19 21:24:59 +02:00
parent 008afc8855
commit 5184236d0f

View File

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