From dc2c491fff69fb05578fc021412ac4e60581d4bf Mon Sep 17 00:00:00 2001 From: Brage Date: Sun, 23 Jul 2023 21:42:00 +0200 Subject: [PATCH] Fix attempt 2 --- .../content/reader/analyzer/encoding/ResultCollection.kt | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/ResultCollection.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/ResultCollection.kt index ab953675..7fa6a1bc 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/ResultCollection.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/ResultCollection.kt @@ -8,11 +8,11 @@ import no.iktdev.streamit.content.common.dto.reader.FileResult import no.iktdev.streamit.content.common.streams.MediaStreams import no.iktdev.streamit.library.kafka.KafkaEvents import no.iktdev.streamit.library.kafka.dto.Message -import no.iktdev.streamit.library.kafka.listener.collector.EventCollection +import no.iktdev.streamit.library.kafka.listener.collector.DefaultEventCollection import no.iktdev.streamit.library.kafka.listener.deserializer.deserializeIfSuccessful import org.apache.kafka.clients.consumer.ConsumerRecord -class ResultCollection: EventCollection() { +class ResultCollection: DefaultEventCollection() { fun getFirstOrNull(events: KafkaEvents): ConsumerRecord? { return getRecords().firstOrNull { it.key() == events.event }