public class io.reactivex.internal.schedulers.NewThreadWorker extends io.reactivex.Scheduler$Worker implements io.reactivex.disposables.Disposable
  minor version: 0
  major version: 59
  flags: flags: (0x0021) ACC_PUBLIC, ACC_SUPER
  this_class: io.reactivex.internal.schedulers.NewThreadWorker
  super_class: io.reactivex.Scheduler$Worker
{
  private final java.util.concurrent.ScheduledExecutorService executor;
    descriptor: Ljava/util/concurrent/ScheduledExecutorService;
    flags: (0x0012) ACC_PRIVATE, ACC_FINAL

  volatile boolean disposed;
    descriptor: Z
    flags: (0x0040) ACC_VOLATILE

  public void <init>(java.util.concurrent.ThreadFactory);
    descriptor: (Ljava/util/concurrent/ThreadFactory;)V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=2, args_size=2
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.util.concurrent.ThreadFactory threadFactory
         0: .line 35
            aload 0 /* this */
            invokespecial io.reactivex.Scheduler$Worker.<init>:()V
         1: .line 36
            aload 0 /* this */
            aload 1 /* threadFactory */
            invokestatic io.reactivex.internal.schedulers.SchedulerPoolFactory.create:(Ljava/util/concurrent/ThreadFactory;)Ljava/util/concurrent/ScheduledExecutorService;
            putfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
         2: .line 37
            return
        end local 1 // java.util.concurrent.ThreadFactory threadFactory
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot           Name  Signature
            0    3     0           this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0    3     1  threadFactory  Ljava/util/concurrent/ThreadFactory;
    MethodParameters:
               Name  Flags
      threadFactory  

  public io.reactivex.disposables.Disposable schedule(java.lang.Runnable);
    descriptor: (Ljava/lang/Runnable;)Lio/reactivex/disposables/Disposable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=2, args_size=2
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.lang.Runnable run
         0: .line 42
            aload 0 /* this */
            aload 1 /* run */
            lconst_0
            aconst_null
            invokevirtual io.reactivex.internal.schedulers.NewThreadWorker.schedule:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
            areturn
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0    1     1   run  Ljava/lang/Runnable;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
    MethodParameters:
      Name  Flags
      run   final

  public io.reactivex.disposables.Disposable schedule(java.lang.Runnable, long, java.util.concurrent.TimeUnit);
    descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=6, locals=5, args_size=4
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.lang.Runnable action
        start local 2 // long delayTime
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 48
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
            ifeq 2
         1: .line 49
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
         2: .line 51
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            aload 1 /* action */
            lload 2 /* delayTime */
            aload 4 /* unit */
            aconst_null
            invokevirtual io.reactivex.internal.schedulers.NewThreadWorker.scheduleActual:(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;Lio/reactivex/internal/disposables/DisposableContainer;)Lio/reactivex/internal/schedulers/ScheduledRunnable;
            areturn
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long delayTime
        end local 1 // java.lang.Runnable action
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0    3     0       this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0    3     1     action  Ljava/lang/Runnable;
            0    3     2  delayTime  J
            0    3     4       unit  Ljava/util/concurrent/TimeUnit;
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
        io.reactivex.annotations.NonNull()
      1:
      2:
        io.reactivex.annotations.NonNull()
    MethodParameters:
           Name  Flags
      action     final
      delayTime  
      unit       

  public io.reactivex.disposables.Disposable scheduleDirect(java.lang.Runnable, long, java.util.concurrent.TimeUnit);
    descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=7, args_size=4
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.lang.Runnable run
        start local 2 // long delayTime
        start local 4 // java.util.concurrent.TimeUnit unit
         0: .line 63
            new io.reactivex.internal.schedulers.ScheduledDirectTask
            dup
            aload 1 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
            invokespecial io.reactivex.internal.schedulers.ScheduledDirectTask.<init>:(Ljava/lang/Runnable;)V
            astore 5 /* task */
        start local 5 // io.reactivex.internal.schedulers.ScheduledDirectTask task
         1: .line 66
            lload 2 /* delayTime */
            lconst_0
            lcmp
            ifgt 4
         2: .line 67
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 5 /* task */
            invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
            astore 6 /* f */
        start local 6 // java.util.concurrent.Future f
         3: .line 68
            goto 5
        end local 6 // java.util.concurrent.Future f
         4: .line 69
      StackMap locals: io.reactivex.internal.schedulers.ScheduledDirectTask
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 5 /* task */
            lload 2 /* delayTime */
            aload 4 /* unit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            astore 6 /* f */
        start local 6 // java.util.concurrent.Future f
         5: .line 71
      StackMap locals: java.util.concurrent.Future
      StackMap stack:
            aload 5 /* task */
            aload 6 /* f */
            invokevirtual io.reactivex.internal.schedulers.ScheduledDirectTask.setFuture:(Ljava/util/concurrent/Future;)V
         6: .line 72
            aload 5 /* task */
         7: areturn
        end local 6 // java.util.concurrent.Future f
         8: .line 73
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.schedulers.ScheduledDirectTask
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 6 /* ex */
        start local 6 // java.util.concurrent.RejectedExecutionException ex
         9: .line 74
            aload 6 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        10: .line 75
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
        end local 6 // java.util.concurrent.RejectedExecutionException ex
        end local 5 // io.reactivex.internal.schedulers.ScheduledDirectTask task
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long delayTime
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot       Name  Signature
            0   11     0       this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0   11     1        run  Ljava/lang/Runnable;
            0   11     2  delayTime  J
            0   11     4       unit  Ljava/util/concurrent/TimeUnit;
            1   11     5       task  Lio/reactivex/internal/schedulers/ScheduledDirectTask;
            3    4     6          f  Ljava/util/concurrent/Future<*>;
            5    8     6          f  Ljava/util/concurrent/Future<*>;
            9   11     6         ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           1     7       8  Class java.util.concurrent.RejectedExecutionException
    MethodParameters:
           Name  Flags
      run        final
      delayTime  
      unit       

  public io.reactivex.disposables.Disposable schedulePeriodicallyDirect(java.lang.Runnable, long, long, java.util.concurrent.TimeUnit);
    descriptor: (Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=7, locals=10, args_size=5
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.lang.Runnable run
        start local 2 // long initialDelay
        start local 4 // long period
        start local 6 // java.util.concurrent.TimeUnit unit
         0: .line 89
            aload 1 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
            astore 7 /* decoratedRun */
        start local 7 // java.lang.Runnable decoratedRun
         1: .line 90
            lload 4 /* period */
            lconst_0
            lcmp
            ifgt 13
         2: .line 92
            new io.reactivex.internal.schedulers.InstantPeriodicTask
            dup
            aload 7 /* decoratedRun */
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokespecial io.reactivex.internal.schedulers.InstantPeriodicTask.<init>:(Ljava/lang/Runnable;Ljava/util/concurrent/ExecutorService;)V
            astore 8 /* periodicWrapper */
        start local 8 // io.reactivex.internal.schedulers.InstantPeriodicTask periodicWrapper
         3: .line 95
            lload 2 /* initialDelay */
            lconst_0
            lcmp
            ifgt 6
         4: .line 96
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 8 /* periodicWrapper */
            invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
            astore 9 /* f */
        start local 9 // java.util.concurrent.Future f
         5: .line 97
            goto 7
        end local 9 // java.util.concurrent.Future f
         6: .line 98
      StackMap locals: java.lang.Runnable io.reactivex.internal.schedulers.InstantPeriodicTask
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 8 /* periodicWrapper */
            lload 2 /* initialDelay */
            aload 6 /* unit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            astore 9 /* f */
        start local 9 // java.util.concurrent.Future f
         7: .line 100
      StackMap locals: java.util.concurrent.Future
      StackMap stack:
            aload 8 /* periodicWrapper */
            aload 9 /* f */
            invokevirtual io.reactivex.internal.schedulers.InstantPeriodicTask.setFirst:(Ljava/util/concurrent/Future;)V
        end local 9 // java.util.concurrent.Future f
         8: .line 101
            goto 12
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long long java.util.concurrent.TimeUnit java.lang.Runnable io.reactivex.internal.schedulers.InstantPeriodicTask
      StackMap stack: java.util.concurrent.RejectedExecutionException
         9: astore 9 /* ex */
        start local 9 // java.util.concurrent.RejectedExecutionException ex
        10: .line 102
            aload 9 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        11: .line 103
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
        end local 9 // java.util.concurrent.RejectedExecutionException ex
        12: .line 106
      StackMap locals:
      StackMap stack:
            aload 8 /* periodicWrapper */
            areturn
        end local 8 // io.reactivex.internal.schedulers.InstantPeriodicTask periodicWrapper
        13: .line 108
      StackMap locals:
      StackMap stack:
            new io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask
            dup
            aload 7 /* decoratedRun */
            invokespecial io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask.<init>:(Ljava/lang/Runnable;)V
            astore 8 /* task */
        start local 8 // io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask task
        14: .line 110
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 8 /* task */
            lload 2 /* initialDelay */
            lload 4 /* period */
            aload 6 /* unit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.scheduleAtFixedRate:(Ljava/lang/Runnable;JJLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            astore 9 /* f */
        start local 9 // java.util.concurrent.Future f
        15: .line 111
            aload 8 /* task */
            aload 9 /* f */
            invokevirtual io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask.setFuture:(Ljava/util/concurrent/Future;)V
        16: .line 112
            aload 8 /* task */
        17: areturn
        end local 9 // java.util.concurrent.Future f
        18: .line 113
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long long java.util.concurrent.TimeUnit java.lang.Runnable io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask
      StackMap stack: java.util.concurrent.RejectedExecutionException
            astore 9 /* ex */
        start local 9 // java.util.concurrent.RejectedExecutionException ex
        19: .line 114
            aload 9 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        20: .line 115
            getstatic io.reactivex.internal.disposables.EmptyDisposable.INSTANCE:Lio/reactivex/internal/disposables/EmptyDisposable;
            areturn
        end local 9 // java.util.concurrent.RejectedExecutionException ex
        end local 8 // io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask task
        end local 7 // java.lang.Runnable decoratedRun
        end local 6 // java.util.concurrent.TimeUnit unit
        end local 4 // long period
        end local 2 // long initialDelay
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot             Name  Signature
            0   21     0             this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0   21     1              run  Ljava/lang/Runnable;
            0   21     2     initialDelay  J
            0   21     4           period  J
            0   21     6             unit  Ljava/util/concurrent/TimeUnit;
            1   21     7     decoratedRun  Ljava/lang/Runnable;
            3   13     8  periodicWrapper  Lio/reactivex/internal/schedulers/InstantPeriodicTask;
            5    6     9                f  Ljava/util/concurrent/Future<*>;
            7    8     9                f  Ljava/util/concurrent/Future<*>;
           10   12     9               ex  Ljava/util/concurrent/RejectedExecutionException;
           14   21     8             task  Lio/reactivex/internal/schedulers/ScheduledDirectPeriodicTask;
           15   18     9                f  Ljava/util/concurrent/Future<*>;
           19   21     9               ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           3     8       9  Class java.util.concurrent.RejectedExecutionException
          14    17      18  Class java.util.concurrent.RejectedExecutionException
    MethodParameters:
              Name  Flags
      run           
      initialDelay  
      period        
      unit          

  public io.reactivex.internal.schedulers.ScheduledRunnable scheduleActual(java.lang.Runnable, long, java.util.concurrent.TimeUnit, io.reactivex.internal.disposables.DisposableContainer);
    descriptor: (Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;Lio/reactivex/internal/disposables/DisposableContainer;)Lio/reactivex/internal/schedulers/ScheduledRunnable;
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=5, locals=10, args_size=5
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
        start local 1 // java.lang.Runnable run
        start local 2 // long delayTime
        start local 4 // java.util.concurrent.TimeUnit unit
        start local 5 // io.reactivex.internal.disposables.DisposableContainer parent
         0: .line 132
            aload 1 /* run */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onSchedule:(Ljava/lang/Runnable;)Ljava/lang/Runnable;
            astore 6 /* decoratedRun */
        start local 6 // java.lang.Runnable decoratedRun
         1: .line 134
            new io.reactivex.internal.schedulers.ScheduledRunnable
            dup
            aload 6 /* decoratedRun */
            aload 5 /* parent */
            invokespecial io.reactivex.internal.schedulers.ScheduledRunnable.<init>:(Ljava/lang/Runnable;Lio/reactivex/internal/disposables/DisposableContainer;)V
            astore 7 /* sr */
        start local 7 // io.reactivex.internal.schedulers.ScheduledRunnable sr
         2: .line 136
            aload 5 /* parent */
            ifnull 5
         3: .line 137
            aload 5 /* parent */
            aload 7 /* sr */
            invokeinterface io.reactivex.internal.disposables.DisposableContainer.add:(Lio/reactivex/disposables/Disposable;)Z
            ifne 5
         4: .line 138
            aload 7 /* sr */
            areturn
         5: .line 144
      StackMap locals: java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
      StackMap stack:
            lload 2 /* delayTime */
            lconst_0
            lcmp
            ifgt 8
         6: .line 145
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 7 /* sr */
            invokeinterface java.util.concurrent.ScheduledExecutorService.submit:(Ljava/util/concurrent/Callable;)Ljava/util/concurrent/Future;
            astore 8 /* f */
        start local 8 // java.util.concurrent.Future f
         7: .line 146
            goto 9
        end local 8 // java.util.concurrent.Future f
         8: .line 147
      StackMap locals:
      StackMap stack:
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            aload 7 /* sr */
            lload 2 /* delayTime */
            aload 4 /* unit */
            invokeinterface java.util.concurrent.ScheduledExecutorService.schedule:(Ljava/util/concurrent/Callable;JLjava/util/concurrent/TimeUnit;)Ljava/util/concurrent/ScheduledFuture;
            astore 8 /* f */
        start local 8 // java.util.concurrent.Future f
         9: .line 149
      StackMap locals: java.util.concurrent.Future
      StackMap stack:
            aload 7 /* sr */
            aload 8 /* f */
            invokevirtual io.reactivex.internal.schedulers.ScheduledRunnable.setFuture:(Ljava/util/concurrent/Future;)V
        10: .line 150
            goto 15
        end local 8 // java.util.concurrent.Future f
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
      StackMap stack: java.util.concurrent.RejectedExecutionException
        11: astore 9 /* ex */
        start local 9 // java.util.concurrent.RejectedExecutionException ex
        12: .line 151
            aload 5 /* parent */
            ifnull 14
        13: .line 152
            aload 5 /* parent */
            aload 7 /* sr */
            invokeinterface io.reactivex.internal.disposables.DisposableContainer.remove:(Lio/reactivex/disposables/Disposable;)Z
            pop
        14: .line 154
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable top java.util.concurrent.RejectedExecutionException
      StackMap stack:
            aload 9 /* ex */
            invokestatic io.reactivex.plugins.RxJavaPlugins.onError:(Ljava/lang/Throwable;)V
        end local 9 // java.util.concurrent.RejectedExecutionException ex
        15: .line 157
      StackMap locals: io.reactivex.internal.schedulers.NewThreadWorker java.lang.Runnable long java.util.concurrent.TimeUnit io.reactivex.internal.disposables.DisposableContainer java.lang.Runnable io.reactivex.internal.schedulers.ScheduledRunnable
      StackMap stack:
            aload 7 /* sr */
            areturn
        end local 7 // io.reactivex.internal.schedulers.ScheduledRunnable sr
        end local 6 // java.lang.Runnable decoratedRun
        end local 5 // io.reactivex.internal.disposables.DisposableContainer parent
        end local 4 // java.util.concurrent.TimeUnit unit
        end local 2 // long delayTime
        end local 1 // java.lang.Runnable run
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot          Name  Signature
            0   16     0          this  Lio/reactivex/internal/schedulers/NewThreadWorker;
            0   16     1           run  Ljava/lang/Runnable;
            0   16     2     delayTime  J
            0   16     4          unit  Ljava/util/concurrent/TimeUnit;
            0   16     5        parent  Lio/reactivex/internal/disposables/DisposableContainer;
            1   16     6  decoratedRun  Ljava/lang/Runnable;
            2   16     7            sr  Lio/reactivex/internal/schedulers/ScheduledRunnable;
            7    8     8             f  Ljava/util/concurrent/Future<*>;
            9   11     8             f  Ljava/util/concurrent/Future<*>;
           12   15     9            ex  Ljava/util/concurrent/RejectedExecutionException;
      Exception table:
        from    to  target  type
           5    10      11  Class java.util.concurrent.RejectedExecutionException
    RuntimeInvisibleAnnotations: 
      io.reactivex.annotations.NonNull()
    RuntimeInvisibleParameterAnnotations: 
      0:
      1:
      2:
        io.reactivex.annotations.NonNull()
      3:
        io.reactivex.annotations.Nullable()
    MethodParameters:
           Name  Flags
      run        final
      delayTime  
      unit       
      parent     

  public void dispose();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
         0: .line 162
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
            ifne 3
         1: .line 163
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
         2: .line 164
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokeinterface java.util.concurrent.ScheduledExecutorService.shutdownNow:()Ljava/util/List;
            pop
         3: .line 166
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactivex/internal/schedulers/NewThreadWorker;

  public void shutdown();
    descriptor: ()V
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=2, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
         0: .line 172
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
            ifne 3
         1: .line 173
            aload 0 /* this */
            iconst_1
            putfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
         2: .line 174
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.executor:Ljava/util/concurrent/ScheduledExecutorService;
            invokeinterface java.util.concurrent.ScheduledExecutorService.shutdown:()V
         3: .line 176
      StackMap locals:
      StackMap stack:
            return
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    4     0  this  Lio/reactivex/internal/schedulers/NewThreadWorker;

  public boolean isDisposed();
    descriptor: ()Z
    flags: (0x0001) ACC_PUBLIC
    Code:
      stack=1, locals=1, args_size=1
        start local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
         0: .line 180
            aload 0 /* this */
            getfield io.reactivex.internal.schedulers.NewThreadWorker.disposed:Z
            ireturn
        end local 0 // io.reactivex.internal.schedulers.NewThreadWorker this
      LocalVariableTable:
        Start  End  Slot  Name  Signature
            0    1     0  this  Lio/reactivex/internal/schedulers/NewThreadWorker;
}
SourceFile: "NewThreadWorker.java"
InnerClasses:
  public abstract Worker = io.reactivex.Scheduler$Worker of io.reactivex.Scheduler