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-12 19:54:11 +02:00
parent 597adb36bc
commit c6d842aefc
4 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -12,10 +12,10 @@ import kotlin.coroutines.cancellation.CancellationException
/**
* Abstract base class for handling tasks with asynchronous processing and reporting.
*
* @param T The type of result produced by processing the task.
* @param reporter An instance of [TaskReporter] for reporting task status and events.
*/
abstract class TaskListener<T>(val taskType: TaskType = TaskType.CPU_INTENSIVE): TaskListenerImplementation {
abstract class TaskListener(val taskType: TaskType = TaskType.CPU_INTENSIVE): TaskListenerImplementation {
init {
TaskListenerRegistry.registerListener(this)

2
src/main/kotlin/no/iktdev/eventi/tasks/TaskListenerRegistry.kt
View File

@ -2,6 +2,6 @@ package no.iktdev.eventi.tasks
import no.iktdev.eventi.ListenerRegistryImplementation
object TaskListenerRegistry: ListenerRegistryImplementation<TaskListener<*>>() {
object TaskListenerRegistry: ListenerRegistryImplementation<TaskListener>() {
}

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

@ -57,7 +57,7 @@ class AbstractTaskPollerTest : TestBase() {
}
open class EchoListener : TaskListener<String>(TaskType.MIXED) {
open class EchoListener : TaskListener(TaskType.MIXED) {
var result: Event? = null
override fun getWorkerId() = this.javaClass.simpleName

2
src/test/kotlin/no/iktdev/eventi/testUtil/TaskListenerRegistryUtil.kt
View File

@ -15,7 +15,7 @@ fun TaskListenerRegistry.wipe() {
// Tøm map’en
val mutableList = field.get(TaskListenerRegistry) as MutableList<*>
(mutableList as MutableList<Class<out TaskListener<*>>>).clear()
(mutableList as MutableList<Class<out TaskListener>>).clear()
// Verifiser at det er tomt
assertThat(TaskListenerRegistry.getListeners().isEmpty())