Class SoulFireReactorScheduler

java.lang.Object
com.soulfiremc.server.script.SoulFireReactorScheduler
All Implemented Interfaces:
reactor.core.Disposable, reactor.core.scheduler.Scheduler
public final class SoulFireReactorScheduler extends Object implements reactor.core.scheduler.Scheduler
Adapter that wraps SoulFireScheduler to implement Reactor's Scheduler interface. This allows reactive pipelines to execute on SoulFire's virtual thread executor.

  • Nested Class Summary

    Nested classes/interfaces inherited from interface reactor.core.Disposable

    reactor.core.Disposable.Composite, reactor.core.Disposable.Swap

    Nested classes/interfaces inherited from interface reactor.core.scheduler.Scheduler

    reactor.core.scheduler.Scheduler.Worker

  • Constructor Summary

    Constructors
    Constructor
    Description
    SoulFireReactorScheduler(SoulFireScheduler delegate)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    reactor.core.scheduler.Scheduler.Worker
    createWorker()
     
    reactor.core.Disposable
    schedule(Runnable task)
     
    reactor.core.Disposable
    schedule(Runnable task, long delay, TimeUnit unit)
     
    reactor.core.Disposable
    schedulePeriodically(Runnable task, long initialDelay, long period, TimeUnit unit)
     

    Methods inherited from class Object

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

    Methods inherited from interface reactor.core.Disposable

    isDisposed

    Methods inherited from interface reactor.core.scheduler.Scheduler

    dispose, disposeGracefully, init, now, start

  • Constructor Details

    • SoulFireReactorScheduler

      public SoulFireReactorScheduler(SoulFireScheduler delegate)

  • Method Details

    • schedule

      public reactor.core.Disposable schedule(Runnable task)
      Specified by:
      schedule in interface reactor.core.scheduler.Scheduler

    • schedule

      public reactor.core.Disposable schedule(Runnable task, long delay, TimeUnit unit)
      Specified by:
      schedule in interface reactor.core.scheduler.Scheduler

    • schedulePeriodically

      public reactor.core.Disposable schedulePeriodically(Runnable task, long initialDelay, long period, TimeUnit unit)
      Specified by:
      schedulePeriodically in interface reactor.core.scheduler.Scheduler

    • createWorker

      public reactor.core.scheduler.Scheduler.Worker createWorker()
      Specified by:
      createWorker in interface reactor.core.scheduler.Scheduler