Added Dokka

Author: Avanatiker

build.gradle.kts

@@ -9,6 +9,7 @@ val yarnMappings = project.properties["yarn_mappings"].toString()
 
 plugins {
     kotlin("jvm") version ("1.9.22")
+    id("org.jetbrains.dokka") version "1.9.20"
     id("architectury-plugin") version "3.4-SNAPSHOT"
     id("dev.architectury.loom") version "1.5-SNAPSHOT" apply false
     id("com.github.johnrengelman.shadow") version "8.1.1" apply false
@@ -20,6 +21,7 @@ architectury {
 
 subprojects {
     apply(plugin = "dev.architectury.loom")
+    apply(plugin = "org.jetbrains.dokka")
     dependencies {
         "minecraft"("com.mojang:minecraft:$minecraftVersion")
         "mappings"("net.fabricmc:yarn:$yarnMappings:v2")

common/src/main/kotlin/com/lambda/event/listener/SafeListener.kt

@@ -17,7 +17,7 @@ class SafeListener(
 //            if (!mc.isOnThread) {
 //                LOG.warn("""
 //                    Event ${this::class.simpleName} executed outside the game thread.
-//                    This can lead to race conditions when manipulating game data.
+//                    This can lead to race conditions when manipulating shared data.
 //                    Consider moving the execution to the game thread using runSafeOnGameThread { ... } or runOnGameThread { ... }.
 //                """.trimIndent())
 //            }

common/src/main/kotlin/com/lambda/task/Task.kt

@@ -66,7 +66,7 @@ abstract class Task<Result>(
     abstract suspend fun SafeContext.onAction(): Result
 
     /**
-     * This function is called when the task is cancelled.
+     * This function is called when the task is canceled.
      * It should be overridden for tasks that need to perform cleanup operations,
      * such as cancelling a block breaking progress, releasing resources,
      * or stopping any ongoing operations that were started by the task.
@@ -107,41 +107,42 @@ abstract class Task<Result>(
 
                     if (iteration == repeats) {
                         onSuccess(result)
-                        stopListening()
+                        tidyUp()
                         return TaskResult.Success(result)
                     }
 
                     onRepeat(iteration)
                 }
-            } catch (e: CancellationException) {
-                stopListening()
-                LOG.warn("Coroutine for task $name cancelled")
-                runSafe {
-                    onCancel()
-                }
-                return TaskResult.Cancelled
             } catch (e: TimeoutCancellationException) {
                 attempt++
                 LOG.warn("Task $name timed out after $age ms and $attempt attempts")
                 onRetry()
-                stopListening()
+                tidyUp()
+            } catch (e: CancellationException) {
+                tidyUp()
+                LOG.warn("Coroutine for task $name cancelled")
+                return TaskResult.Cancelled
             } catch (e: Throwable) {
                 attempt++
                 LOG.error("Task $name failed after $age ms and $attempt attempts", e)
                 onException(e)
-                stopListening()
+                tidyUp()
                 return TaskResult.Failure(e)
             }
 
-            stopListening()
+            tidyUp()
         } while (attempt < maxAttempts || iteration <= repeats)
 
         LOG.error("Task $name fully timed out after $age ms and $attempt attempts")
         onTimeout()
         return TaskResult.Timeout(timeout, attempt)
     }
 
-    private fun stopListening() {
+    private fun tidyUp() {
+        runSafe {
+            onCancel()
+        }
+
         EventFlow.syncListeners.unsubscribe(syncListeners)
         EventFlow.concurrentListeners.unsubscribe(concurrentListeners)