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

Fixed signature

Browse Source
This commit is contained in:
Brage Skjønborg 2025-10-13 20:31:26 +02:00
parent c6d842aefc
commit 7c2e1b09f1
2 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/kotlin/no/iktdev/eventi/tasks/TaskListener.kt
View File

@ -21,8 +21,7 @@ abstract class TaskListener(val taskType: TaskType = TaskType.CPU_INTENSIVE): Ta
TaskListenerRegistry.registerListener(this) TaskListenerRegistry.registerListener(this)
} }
var reporter: TaskReporter? = null abstract var reporter: TaskReporter?
private set
abstract fun getWorkerId(): String abstract fun getWorkerId(): String
protected var currentJob: Job? = null protected var currentJob: Job? = null
var currentTask: Task? = null var currentTask: Task? = null

6
src/test/kotlin/no/iktdev/eventi/tasks/AbstractTaskPollerTest.kt
View File

@ -1,13 +1,11 @@
package no.iktdev.eventi.tasks package no.iktdev.eventi.tasks
import io.mockk.mockk
import kotlinx.coroutines.CompletableDeferred import kotlinx.coroutines.CompletableDeferred
import kotlinx.coroutines.ExperimentalCoroutinesApi import kotlinx.coroutines.ExperimentalCoroutinesApi
import kotlinx.coroutines.test.advanceUntilIdle import kotlinx.coroutines.test.advanceUntilIdle
import kotlinx.coroutines.test.runTest import kotlinx.coroutines.test.runTest
import no.iktdev.eventi.InMemoryTaskStore import no.iktdev.eventi.InMemoryTaskStore
import no.iktdev.eventi.TestBase import no.iktdev.eventi.TestBase
import no.iktdev.eventi.events.EventListener
import no.iktdev.eventi.events.EventTypeRegistry import no.iktdev.eventi.events.EventTypeRegistry
import no.iktdev.eventi.models.Event import no.iktdev.eventi.models.Event
import no.iktdev.eventi.models.Task import no.iktdev.eventi.models.Task
@ -60,6 +58,8 @@ class AbstractTaskPollerTest : TestBase() {
open class EchoListener : TaskListener(TaskType.MIXED) { open class EchoListener : TaskListener(TaskType.MIXED) {
var result: Event? = null var result: Event? = null
override var reporter: TaskReporter? = null
override fun getWorkerId() = this.javaClass.simpleName override fun getWorkerId() = this.javaClass.simpleName
override fun supports(task: Task): Boolean { override fun supports(task: Task): Boolean {
@ -98,7 +98,7 @@ class AbstractTaskPollerTest : TestBase() {
advanceUntilIdle() advanceUntilIdle()
val producedEvent = eventDeferred.await() val producedEvent = eventDeferred.await()
assertThat(producedEvent).isNotNull assertThat(producedEvent).isNotNull
assertThat(producedEvent!!.metadata.derivedFromId).isEqualTo(task.taskId) assertThat(producedEvent.metadata.derivedFromId).isEqualTo(task.taskId)
assertThat((listener.result as EchoEvent).data).isEqualTo("Hello Potetmos") assertThat((listener.result as EchoEvent).data).isEqualTo("Hello Potetmos")
} }