getkyo · fwbrasil · Dec 17, 2024 · Dec 17, 2024 · Dec 17, 2024 · Dec 17, 2024
diff --git a/kyo-bench/src/main/scala/kyo/bench/TRefMultiBench.scala b/kyo-bench/src/main/scala/kyo/bench/TRefMultiBench.scala
@@ -1,7 +1,5 @@
 package kyo.bench
 
-import java.util.concurrent.locks.LockSupport
-
 class TRefMultiBench(parallelism: Int) extends Bench.ForkOnly(parallelism):
 
     def this() = this(Runtime.getRuntime().availableProcessors() * 2)

diff --git a/kyo-bench/src/main/scala/kyo/bench/TRefSingleBench.scala b/kyo-bench/src/main/scala/kyo/bench/TRefSingleBench.scala
@@ -1,7 +1,5 @@
 package kyo.bench
 
-import java.util.concurrent.locks.LockSupport
-
 class TRefSingleBench(parallelism: Int) extends Bench.ForkOnly(parallelism):
 
     def this() = this(Runtime.getRuntime().availableProcessors() * 2)

diff --git a/kyo-cats/shared/src/main/scala/kyo/Cats.scala b/kyo-cats/shared/src/main/scala/kyo/Cats.scala
@@ -5,7 +5,6 @@ import kyo.kernel.*
 import scala.concurrent.ExecutionContext
 import scala.util.Failure
 import scala.util.Success
-import scala.util.control.NonFatal
 
 object Cats:
 

diff --git a/kyo-combinators/shared/src/main/scala/kyo/Combinators.scala b/kyo-combinators/shared/src/main/scala/kyo/Combinators.scala
@@ -2,7 +2,6 @@ package kyo
 
 import kyo.debug.Debug
 import kyo.kernel.Boundary
-import kyo.kernel.Reducible
 import scala.annotation.tailrec
 import scala.annotation.targetName
 import scala.util.NotGiven

diff --git a/kyo-combinators/shared/src/main/scala/kyo/Constructors.scala b/kyo-combinators/shared/src/main/scala/kyo/Constructors.scala
@@ -1,8 +1,6 @@
 package kyo
 
 import java.io.IOException
-import kyo.kernel.Reducible
-import scala.annotation.tailrec
 import scala.concurrent.Future
 import scala.util.Failure
 import scala.util.NotGiven

diff --git a/kyo-combinators/shared/src/test/scala/kyo/AbortCombinatorTest.scala b/kyo-combinators/shared/src/test/scala/kyo/AbortCombinatorTest.scala
@@ -1,6 +1,5 @@
 package kyo
 
-import scala.concurrent.Future
 import scala.util.Try
 
 class AbortCombinatorTest extends Test:

diff --git a/kyo-core/jvm-native/src/main/scala/kyo/KyoAppPlatformSpecific.scala b/kyo-core/jvm-native/src/main/scala/kyo/KyoAppPlatformSpecific.scala
@@ -1,7 +1,5 @@
 package kyo
 
-import scala.collection.mutable.ListBuffer
-
 abstract class KyoAppPlatformSpecific extends KyoApp.Base[Async & Resource & Abort[Throwable]]:
 
     final override protected def run[A: Flat](v: => A < (Async & Resource & Abort[Throwable]))(using Frame): Unit =

diff --git a/kyo-core/jvm/src/test/scala/kyo/internal/SignalTest.scala b/kyo-core/jvm/src/test/scala/kyo/internal/SignalTest.scala
@@ -3,7 +3,6 @@ package kyo.internal
 import java.util.concurrent.CountDownLatch
 import java.util.concurrent.TimeUnit
 import kyo.Test
-import kyo.kernel.Platform
 
 class SignalTest extends Test:
 

diff --git a/kyo-core/native/src/main/scala/kyo/hubsStubs.scala b/kyo-core/native/src/main/scala/kyo/hubsStubs.scala
@@ -1,7 +1,6 @@
 package java.util.concurrent
 
 import java.util.function.Predicate
-import kyo.discard
 import scala.collection.mutable
 import scala.reflect.ClassTag
 

diff --git a/kyo-core/native/src/main/scala/kyo/queuesStubs.scala b/kyo-core/native/src/main/scala/kyo/queuesStubs.scala
@@ -1,7 +1,5 @@
 package org.jctools.queues
 
-import java.util.ArrayDeque
-import java.util.concurrent.ArrayBlockingQueue
 import java.util.concurrent.LinkedBlockingQueue
 import scala.annotation.tailrec
 

diff --git a/kyo-core/shared/src/main/scala/kyo/Channel.scala b/kyo-core/shared/src/main/scala/kyo/Channel.scala
@@ -1,6 +1,5 @@
 package kyo
 
-import org.jctools.queues.MessagePassingQueue.Consumer
 import org.jctools.queues.MpmcUnboundedXaddArrayQueue
 import scala.annotation.tailrec
 

diff --git a/kyo-core/shared/src/main/scala/kyo/Fiber.scala b/kyo-core/shared/src/main/scala/kyo/Fiber.scala
@@ -4,12 +4,11 @@ export Fiber.Promise
 import java.lang.invoke.VarHandle
 import java.util.Arrays
 import kyo.Result.Panic
-import kyo.Tag
 import kyo.internal.FiberPlatformSpecific
 import kyo.kernel.*
+import kyo.kernel.internal.*
 import kyo.scheduler.*
 import scala.annotation.tailrec
-import scala.collection.immutable.ArraySeq
 import scala.concurrent.ExecutionContext
 import scala.concurrent.Future
 import scala.util.NotGiven

diff --git a/kyo-core/shared/src/main/scala/kyo/IO.scala b/kyo-core/shared/src/main/scala/kyo/IO.scala
@@ -2,6 +2,7 @@ package kyo
 
 import kyo.Tag
 import kyo.kernel.*
+import kyo.kernel.internal.Safepoint
 
 /** Represents an IO effect for handling side effects in a pure functional manner.
   *

diff --git a/kyo-core/shared/src/main/scala/kyo/System.scala b/kyo-core/shared/src/main/scala/kyo/System.scala
@@ -5,7 +5,6 @@ import java.lang.System as JSystem
 import java.net.MalformedURLException
 import java.net.URISyntaxException
 import java.time.format.DateTimeParseException
-import kyo.kernel.Reducible
 
 /** Represents a system environment with various operations.
   *

diff --git a/kyo-core/shared/src/main/scala/kyo/Timeout.scala b/kyo-core/shared/src/main/scala/kyo/Timeout.scala
@@ -1,5 +1,3 @@
 package kyo
 
-import scala.util.control.NoStackTrace
-
 class Timeout()(using Frame) extends KyoException(t"Computation has timed out.")
diff --git a/kyo-core/shared/src/main/scala/kyo/scheduler/IOPromise.scala b/kyo-core/shared/src/main/scala/kyo/scheduler/IOPromise.scala
@@ -5,11 +5,10 @@ import java.util.concurrent.atomic.AtomicReference
 import java.util.concurrent.locks.LockSupport
 import kyo.*
 import kyo.Result.Error
-import kyo.kernel.Safepoint
+import kyo.kernel.internal.Safepoint
 import scala.annotation.nowarn
 import scala.annotation.tailrec
 import scala.util.control.NonFatal
-import scala.util.control.NoStackTrace
 
 private[kyo] class IOPromise[+E, +A](init: State[E, A]) extends Safepoint.Interceptor:
 

diff --git a/kyo-core/shared/src/main/scala/kyo/scheduler/IOTask.scala b/kyo-core/shared/src/main/scala/kyo/scheduler/IOTask.scala
@@ -4,6 +4,7 @@ import kyo.*
 import kyo.Tag
 import kyo.kernel.*
 import kyo.kernel.ArrowEffect
+import kyo.kernel.internal.*
 import kyo.scheduler.IOTask.*
 import scala.util.control.NonFatal
 

diff --git a/kyo-core/shared/src/test/scala/kyo/KyoAppTest.scala b/kyo-core/shared/src/test/scala/kyo/KyoAppTest.scala
@@ -1,10 +1,6 @@
 package kyo
 
 import Tagged.*
-import kyo.Clock.Deadline
-import kyo.Clock.Stopwatch
-import kyo.Clock.Unsafe
-import kyo.internal.LayerMacros.Validated.succeed
 import org.scalatest.compatible.Assertion
 import scala.collection.mutable.ListBuffer
 import scala.util.Try

diff --git a/kyo-core/shared/src/test/scala/kyo/kernel/TagCompactTest.scala b/kyo-core/shared/src/test/scala/kyo/kernel/TagCompactTest.scala
@@ -2,7 +2,6 @@ package kyo.kernel
 
 import kyo.*
 import kyo.kernel.internal.Defer
-import org.scalatest.NonImplicitAssertions
 import org.scalatest.compatible.Assertion
 
 class TagCompactTest extends Test:

diff --git a/kyo-data/shared/src/main/scala/kyo/Chunk.scala b/kyo-data/shared/src/main/scala/kyo/Chunk.scala
@@ -1,7 +1,6 @@
 package kyo
 
 import Chunk.Indexed
-import java.util.Arrays
 import scala.annotation.tailrec
 import scala.annotation.targetName
 import scala.collection.StrictOptimizedSeqFactory

diff --git a/kyo-data/shared/src/main/scala/kyo/Render.scala b/kyo-data/shared/src/main/scala/kyo/Render.scala
@@ -1,6 +1,5 @@
 package kyo
 
-import kyo.Schedule.done
 import scala.annotation.nowarn
 import scala.language.implicitConversions
 

diff --git a/kyo-data/shared/src/main/scala/kyo/internal/TagMacro.scala b/kyo-data/shared/src/main/scala/kyo/internal/TagMacro.scala
@@ -133,42 +133,42 @@ object TagMacro:
     end concat
 
     val toCompact = Map(
-        "java.lang.Object"                    -> "0",
-        "scala.Matchable"                     -> "1",
-        "scala.Any"                           -> "2",
-        "scala.AnyVal"                        -> "3",
-        "java.lang.String"                    -> "4",
-        "scala.Int"                           -> "5",
-        "scala.Long"                          -> "6",
-        "scala.Float"                         -> "7",
-        "scala.Double"                        -> "8",
-        "scala.Boolean"                       -> "9",
-        "scala.Unit"                          -> "a",
-        "scala.Option"                        -> "b",
-        "scala.Some"                          -> "c",
-        "scala.None"                          -> "d",
-        "scala.Left"                          -> "e",
-        "scala.Right"                         -> "f",
-        "scala.Tuple2"                        -> "g",
-        "scala.collection.immutable.List"     -> "h",
-        "scala.collection.immutable.Nil"      -> "i",
-        "scala.collection.immutable.Map"      -> "j",
-        "scala.Nothing"                       -> "k",
-        "java.lang.CharSequence"              -> "l",
-        "java.lang.Comparable"                -> "m",
-        "java.io.Serializable"                -> "n",
-        "scala.Product"                       -> "o",
-        "scala.Equals"                        -> "p",
-        "kyo.kernel.Effect"                   -> "q",
-        "kyo.kernel.ContextEffect"            -> "r",
-        "kyo.kernel.ArrowEffect"              -> "s",
-        "kyo.Abort"                           -> "t",
-        "kyo.Async$package$.Async$.Join"      -> "u",
-        "kyo.Emit"                            -> "v",
-        "scala.Char"                          -> "w",
-        "java.lang.Throwable"                 -> "x",
-        "java.lang.Exception"                 -> "y",
-        "kyo.kernel.package$.internal$.Defer" -> "z"
+        "java.lang.Object"                -> "0",
+        "scala.Matchable"                 -> "1",
+        "scala.Any"                       -> "2",
+        "scala.AnyVal"                    -> "3",
+        "java.lang.String"                -> "4",
+        "scala.Int"                       -> "5",
+        "scala.Long"                      -> "6",
+        "scala.Float"                     -> "7",
+        "scala.Double"                    -> "8",
+        "scala.Boolean"                   -> "9",
+        "scala.Unit"                      -> "a",
+        "scala.Option"                    -> "b",
+        "scala.Some"                      -> "c",
+        "scala.None"                      -> "d",
+        "scala.Left"                      -> "e",
+        "scala.Right"                     -> "f",
+        "scala.Tuple2"                    -> "g",
+        "scala.collection.immutable.List" -> "h",
+        "scala.collection.immutable.Nil"  -> "i",
+        "scala.collection.immutable.Map"  -> "j",
+        "scala.Nothing"                   -> "k",
+        "java.lang.CharSequence"          -> "l",
+        "java.lang.Comparable"            -> "m",
+        "java.io.Serializable"            -> "n",
+        "scala.Product"                   -> "o",
+        "scala.Equals"                    -> "p",
+        "kyo.kernel.Effect"               -> "q",
+        "kyo.kernel.ContextEffect"        -> "r",
+        "kyo.kernel.ArrowEffect"          -> "s",
+        "kyo.Abort"                       -> "t",
+        "kyo.Async$package$.Async$.Join"  -> "u",
+        "kyo.Emit"                        -> "v",
+        "scala.Char"                      -> "w",
+        "java.lang.Throwable"             -> "x",
+        "java.lang.Exception"             -> "y",
+        "kyo.kernel.internal.Defer"       -> "z"
     )
 
     val fromCompact = toCompact.map(_.swap).toMap

diff --git a/kyo-data/shared/src/test/scala/kyo/MaybeTest.scala b/kyo-data/shared/src/test/scala/kyo/MaybeTest.scala
@@ -2,7 +2,6 @@ package kyo
 
 import kyo.Maybe.*
 import kyo.Maybe.internal.PresentAbsent
-import scala.languageFeature.implicitConversions
 
 class MaybeTest extends Test:
 

diff --git a/kyo-data/shared/src/test/scala/kyo/Test.scala b/kyo-data/shared/src/test/scala/kyo/Test.scala
@@ -3,7 +3,6 @@ package kyo
 import org.scalatest.Assertion
 import org.scalatest.NonImplicitAssertions
 import org.scalatest.freespec.AsyncFreeSpec
-import scala.compiletime.testing.Error
 import scala.compiletime.testing.typeCheckErrors
 import scala.util.Try
 

diff --git a/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala b/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala
@@ -1,6 +1,5 @@
-package kyo.kernel
+package kyo.kernel.internal
 
-import internal.*
 import kyo.Frame
 
 private[kernel] object TracePool:

diff --git a/kyo-kernel/jvm/src/main/scala/kyo/kernel/Platform.scala b/kyo-kernel/jvm/src/main/scala/kyo/kernel/Platform.scala
@@ -1,14 +1,9 @@
 package kyo.kernel
 
-import kyo.kernel.Mode
 import scala.concurrent.ExecutionContext
 
 object Platform:
 
-    val mode: Mode =
-        Option(System.getProperty("kyo.kernel.Platform.mode"))
-            .map(Mode.valueOf).getOrElse(Mode.Development)
-
     val executionContext: ExecutionContext = scala.concurrent.ExecutionContext.global
     val isJVM: Boolean                     = true
     val isJS: Boolean                      = false

diff --git a/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala b/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala
@@ -1,7 +1,7 @@
-package kyo.kernel
+package kyo.kernel.internal
 
-import internal.*
 import java.util.Arrays
+import kyo.kernel.internal.*
 import org.jctools.queues.MessagePassingQueue.Consumer
 import org.jctools.queues.MpmcArrayQueue
 

diff --git a/...test/scala/kyo/kernel/SafepointTest.scala → ...a/kyo/kernel/internal/SafepointTest.scala b/...test/scala/kyo/kernel/SafepointTest.scala → ...a/kyo/kernel/internal/SafepointTest.scala
@@ -1,8 +1,9 @@
-package kyo.kernel
+package kyo.kernel.internal
 
 import kyo.*
 import kyo.Tag
 import kyo.Tagged.*
+import kyo.kernel.*
 import scala.concurrent.Await
 import scala.concurrent.Future
 

diff --git a/kyo-kernel/native/src/main/scala/kyo/kernel/Platform.scala b/kyo-kernel/native/src/main/scala/kyo/kernel/Platform.scala
@@ -1,14 +1,9 @@
 package kyo.kernel
 
-import kyo.kernel.Mode
 import scala.concurrent.ExecutionContext
 
 object Platform:
 
-    val mode: Mode =
-        Option(System.getProperty("kyo.kernel.Platform.mode"))
-            .map(Mode.valueOf).getOrElse(Mode.Development)
-
     val executionContext: ExecutionContext = scala.concurrent.ExecutionContext.global
     val isJVM: Boolean                     = false
     val isJS: Boolean                      = false

diff --git a/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala b/...src/main/scala/kyo/kernel/TracePool.scala → ...scala/kyo/kernel/internal/TracePool.scala
@@ -1,11 +1,8 @@
-package kyo.kernel
+package kyo.kernel.internal
 
-import internal.*
 import java.util.Arrays
 import java.util.concurrent.ConcurrentLinkedQueue
-import java.util.concurrent.atomic.AtomicInteger
 import kyo.discard
-import scala.annotation.tailrec
 
 private[kernel] object TracePool:
     inline def globalCapacity: Int = 8192

diff --git a/kyo-kernel/shared/src/main/scala/kyo/Kyo.scala b/kyo-kernel/shared/src/main/scala/kyo/Kyo.scala
@@ -1,7 +1,7 @@
 package kyo
 
 import kernel.Loop
-import kyo.kernel.Safepoint
+import kyo.kernel.internal.Safepoint
 import scala.annotation.tailrec
 
 /** Object containing utility functions for working with Kyo effects. */

diff --git a/kyo-kernel/shared/src/main/scala/kyo/kernel/ArrowEffect.scala b/kyo-kernel/shared/src/main/scala/kyo/kernel/ArrowEffect.scala
@@ -1,10 +1,7 @@
 package kyo.kernel
 
-import internal.*
-import kyo.Const
-import kyo.Flat
-import kyo.Frame
-import kyo.Tag
+import kyo.*
+import kyo.kernel.internal.*
 import scala.annotation.nowarn
 import scala.util.control.NonFatal
 

diff --git a/kyo-kernel/shared/src/main/scala/kyo/kernel/Boundary.scala b/kyo-kernel/shared/src/main/scala/kyo/kernel/Boundary.scala
@@ -1,9 +1,8 @@
 package kyo.kernel
 
-import internal.*
 import kyo.Ansi.*
 import kyo.Frame
-import scala.annotation.implicitNotFound
+import kyo.kernel.internal.*
 import scala.annotation.nowarn
 import scala.quoted.*
 

diff --git a/kyo-kernel/shared/src/main/scala/kyo/kernel/ContextEffect.scala b/kyo-kernel/shared/src/main/scala/kyo/kernel/ContextEffect.scala
@@ -1,12 +1,8 @@
 package kyo.kernel
 
-import internal.*
-import kyo.Flat
-import kyo.Frame
-import kyo.Tag
-import kyo.bug
+import kyo.*
+import kyo.kernel.internal.*
 import scala.annotation.nowarn
-import scala.util.NotGiven
 
 /** Represents the requirement for a value that will be provided later by a handler.
   *