iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix attempt 2

Browse Source
This commit is contained in:
Brage 2023-07-23 21:42:00 +02:00
parent 73491ba18e
commit dc2c491fff
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/ResultCollection.kt
View File

@ -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.content.common.streams.MediaStreams
import no.iktdev.streamit.library.kafka.KafkaEvents import no.iktdev.streamit.library.kafka.KafkaEvents
import no.iktdev.streamit.library.kafka.dto.Message 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 no.iktdev.streamit.library.kafka.listener.deserializer.deserializeIfSuccessful
import org.apache.kafka.clients.consumer.ConsumerRecord import org.apache.kafka.clients.consumer.ConsumerRecord
class ResultCollection: EventCollection() { class ResultCollection: DefaultEventCollection() {
fun getFirstOrNull(events: KafkaEvents): ConsumerRecord<String, Message>? { fun getFirstOrNull(events: KafkaEvents): ConsumerRecord<String, Message>? {
return getRecords().firstOrNull { it.key() == events.event } return getRecords().firstOrNull { it.key() == events.event }