@@ -21,6 +21,8 @@ import cats.effect.kernel.Resource
2121import cats .effect .unsafe .Scheduler
2222import org .http4s .curl .CurlError
2323
24+ import java .util .ArrayDeque
25+ import java .util .PriorityQueue
2426import scala .collection .mutable
2527import scala .concurrent .ExecutionContext
2628import scala .concurrent .ExecutionContextExecutor
@@ -29,8 +31,6 @@ import scala.scalanative.unsafe._
2931import scala .scalanative .unsigned ._
3032import scala .util .control .NonFatal
3133
32- import java .util .{ArrayDeque , PriorityQueue }
33-
3434final class CurlExecutorScheduler (
3535 private [this ] val multiHandle : Ptr [libcurl.CURLM ],
3636 private [this ] val pollEvery : Int ,
@@ -40,8 +40,8 @@ final class CurlExecutorScheduler(
4040 private [this ] var needsReschedule : Boolean = true
4141 private [this ] val executeQueue : ArrayDeque [Runnable ] = new ArrayDeque
4242 private [this ] val sleepQueue : PriorityQueue [SleepTask ] = new PriorityQueue
43- private [this ] val callbacks
44- : mutable. Map [ Ptr [libcurl. CURL ], Either [ Throwable , Unit ] => Unit ] = mutable.Map .empty
43+ private [this ] val callbacks : mutable. Map [ Ptr [libcurl. CURL ], Either [ Throwable , Unit ] => Unit ] =
44+ mutable.Map .empty
4545 private [this ] val noop : Runnable = () => ()
4646
4747 // ExecutionContext
@@ -184,7 +184,7 @@ final class CurlExecutorScheduler(
184184 IO (callbacks.remove(handle).foreach(_(Right (()))))
185185 }
186186
187- private [this ] final class SleepTask (val at : Long , val runnable : Runnable )
187+ final private [this ] class SleepTask (val at : Long , val runnable : Runnable )
188188 extends Runnable
189189 with Comparable [SleepTask ] {
190190 def run (): Unit = { sleepQueue.remove(this ); () }
0 commit comments