Package io.reactivex.rxjava3.internal.schedulers

Class SingleScheduler.ScheduledWorker

    • Field Summary

      Fields 
      Modifier and Type Field Description
      (package private) boolean disposed  
      (package private) java.util.concurrent.ScheduledExecutorService executor  
      (package private) CompositeDisposable tasks  

    • Constructor Summary

      Constructors 
      Constructor Description
      ScheduledWorker​(java.util.concurrent.ScheduledExecutorService executor)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void dispose()
      Dispose the resource, the operation should be idempotent.
      boolean isDisposed()
      Returns true if this resource has been disposed.
      @NonNull Disposable schedule​(@NonNull java.lang.Runnable run, long delay, @NonNull java.util.concurrent.TimeUnit unit)
      Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • executor

        final java.util.concurrent.ScheduledExecutorService executor

      • disposed

        volatile boolean disposed

    • Constructor Detail

      • ScheduledWorker

        ScheduledWorker​(java.util.concurrent.ScheduledExecutorService executor)

    • Method Detail

      • schedule

        @NonNull
public @NonNull Disposable schedule​(@NonNull
                                    @NonNull java.lang.Runnable run,
                                    long delay,
                                    @NonNull
                                    @NonNull java.util.concurrent.TimeUnit unit)
        Description copied from class: Scheduler.Worker
        Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

        Note to implementors: non-positive delayTime should be regarded as non-delayed schedule, i.e., as if the Scheduler.Worker.schedule(Runnable) was called.

        Specified by:
        schedule in class Scheduler.Worker
        Parameters:
        run - the Runnable to schedule
        delay - time to "wait" before executing the action; non-positive values indicate an non-delayed schedule
        unit - the time unit of delayTime
        Returns:
        a Disposable to be able to unsubscribe the action (cancel it if not executed)

      • dispose

        public void dispose()
        Description copied from interface: Disposable
        Dispose the resource, the operation should be idempotent.

      • isDisposed

        public boolean isDisposed()
        Description copied from interface: Disposable
        Returns true if this resource has been disposed.
        Returns:
        true if this resource has been disposed