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

Minor corrections

Browse Source
This commit is contained in:
Brage 2023-07-20 17:09:31 +02:00
parent 31f4851401
commit c2ac823e25
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/build.gradle.kts
View File

@ -23,7 +23,7 @@ repositories {
} }
dependencies { dependencies {
implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha47") implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha48")
implementation("no.iktdev:exfl:0.0.8-SNAPSHOT") implementation("no.iktdev:exfl:0.0.8-SNAPSHOT")

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/contentDeterminator/ContentDeterminate.kt
View File

@ -35,7 +35,7 @@ class ContentDeterminate: DefaultKafkaReader("contentDeterminate"), ISequentialM
override fun getRequiredMessages(): List<String> { override fun getRequiredMessages(): List<String> {
return listOf(KafkaEvents.EVENT_READER_RECEIVED_FILE.event, KafkaEvents.EVENT_METADATA_OBTAINED.event) return mainListener.subAccepts + listOf(mainListener.accept)
} }
override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) { override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) {

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

@ -46,7 +46,7 @@ class EncodedStreams : ISequentialMessageEvent {
override fun getRequiredMessages(): List<String> { override fun getRequiredMessages(): List<String> {
return listOf(KafkaEvents.EVENT_READER_RECEIVED_FILE.event, KafkaEvents.EVENT_READER_RECEIVED_STREAMS.event) return mainListener.subAccepts + listOf(mainListener.accept)
} }
override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) { override fun onAllMessagesProcessed(referenceId: String, result: Map<String, Message?>) {