Package org.apache.pekko.http.impl.engine.client.pool

Class NewHostConnectionPoolSpec.TrackingScheduler

java.lang.Object
org.apache.pekko.actor.LightArrayRevolverScheduler
org.apache.pekko.http.impl.engine.client.pool.NewHostConnectionPoolSpec.TrackingScheduler
All Implemented Interfaces:
Closeable, AutoCloseable, org.apache.pekko.actor.Scheduler
Enclosing class:
NewHostConnectionPoolSpec
public static final class NewHostConnectionPoolSpec.TrackingScheduler extends org.apache.pekko.actor.LightArrayRevolverScheduler
Records the tasks scheduled for NewHostConnectionPoolSpec.SlotStateTimeout() so that a test can check whether they are cancelled

  • Nested Class Summary

    Nested classes/interfaces inherited from class org.apache.pekko.actor.LightArrayRevolverScheduler

    org.apache.pekko.actor.LightArrayRevolverScheduler.TaskHolder, org.apache.pekko.actor.LightArrayRevolverScheduler.TimerTask

    Nested classes/interfaces inherited from interface org.apache.pekko.actor.Scheduler

    org.apache.pekko.actor.Scheduler.AtomicCancellable, org.apache.pekko.actor.Scheduler.TaskRunOnClose

  • Field Summary

    Fields inherited from class org.apache.pekko.actor.LightArrayRevolverScheduler

    org$apache$pekko$actor$LightArrayRevolverScheduler$$log, org$apache$pekko$actor$LightArrayRevolverScheduler$$threadFactory

  • Constructor Summary

    Constructors
    Constructor
    Description
    TrackingScheduler(com.typesafe.config.Config config, org.apache.pekko.event.LoggingAdapter log, ThreadFactory threadFactory)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pekko.actor.Cancellable
    scheduleOnce(scala.concurrent.duration.FiniteDuration delay, Runnable runnable, scala.concurrent.ExecutionContext executor)
     

    Methods inherited from class org.apache.pekko.actor.LightArrayRevolverScheduler

    clock, close, getShutdownTimeout, maxFrequency, org$apache$pekko$actor$LightArrayRevolverScheduler$$queue, org$apache$pekko$actor$LightArrayRevolverScheduler$$roundUp, org$apache$pekko$actor$LightArrayRevolverScheduler$$schedule, org$apache$pekko$actor$LightArrayRevolverScheduler$$start, org$apache$pekko$actor$LightArrayRevolverScheduler$$stopped, org$apache$pekko$actor$LightArrayRevolverScheduler$$tickNanos, org$apache$pekko$actor$LightArrayRevolverScheduler$$timerThread_$eq, org$apache$pekko$actor$LightArrayRevolverScheduler$$wheelMask, schedule, scheduleAtFixedRate, scheduleAtFixedRate, scheduleAtFixedRate, scheduleAtFixedRate, scheduleAtFixedRate$default$6, scheduleOnce, scheduleOnce, scheduleOnce, scheduleOnce, scheduleOnce$default$5, scheduleWithFixedDelay, scheduleWithFixedDelay, scheduleWithFixedDelay, scheduleWithFixedDelay, scheduleWithFixedDelay$default$6, ShutdownTimeout, startTick, TickDuration, waitNanos, WheelSize

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • TrackingScheduler

      public TrackingScheduler(com.typesafe.config.Config config, org.apache.pekko.event.LoggingAdapter log, ThreadFactory threadFactory)

  • Method Details

    • scheduleOnce

      public org.apache.pekko.actor.Cancellable scheduleOnce(scala.concurrent.duration.FiniteDuration delay, Runnable runnable, scala.concurrent.ExecutionContext executor)
      Specified by:
      scheduleOnce in interface org.apache.pekko.actor.Scheduler
      Overrides:
      scheduleOnce in class org.apache.pekko.actor.LightArrayRevolverScheduler