SchedulerWhen$DelayedAction.smali 2.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465
  1. .class Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;
  2. .super Lio/reactivex/internal/schedulers/SchedulerWhen$ScheduledAction;
  3. .source "SchedulerWhen.java"
  4. # annotations
  5. .annotation system Ldalvik/annotation/EnclosingClass;
  6. value = Lio/reactivex/internal/schedulers/SchedulerWhen;
  7. .end annotation
  8. .annotation system Ldalvik/annotation/InnerClass;
  9. accessFlags = 0x8
  10. name = "DelayedAction"
  11. .end annotation
  12. # instance fields
  13. .field private final action:Ljava/lang/Runnable;
  14. .field private final delayTime:J
  15. .field private final unit:Ljava/util/concurrent/TimeUnit;
  16. # direct methods
  17. .method constructor <init>(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)V
  18. .locals 0
  19. .line 286
  20. invoke-direct {p0}, Lio/reactivex/internal/schedulers/SchedulerWhen$ScheduledAction;-><init>()V
  21. .line 287
  22. iput-object p1, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->action:Ljava/lang/Runnable;
  23. .line 288
  24. iput-wide p2, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->delayTime:J
  25. .line 289
  26. iput-object p4, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->unit:Ljava/util/concurrent/TimeUnit;
  27. return-void
  28. .end method
  29. # virtual methods
  30. .method protected callActual(Lio/reactivex/Scheduler$Worker;Lio/reactivex/CompletableObserver;)Lio/reactivex/disposables/Disposable;
  31. .locals 3
  32. .line 294
  33. new-instance v0, Lio/reactivex/internal/schedulers/SchedulerWhen$OnCompletedAction;
  34. iget-object v1, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->action:Ljava/lang/Runnable;
  35. invoke-direct {v0, v1, p2}, Lio/reactivex/internal/schedulers/SchedulerWhen$OnCompletedAction;-><init>(Ljava/lang/Runnable;Lio/reactivex/CompletableObserver;)V
  36. iget-wide v1, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->delayTime:J
  37. iget-object p2, p0, Lio/reactivex/internal/schedulers/SchedulerWhen$DelayedAction;->unit:Ljava/util/concurrent/TimeUnit;
  38. invoke-virtual {p1, v0, v1, v2, p2}, Lio/reactivex/Scheduler$Worker;->schedule(Ljava/lang/Runnable;JLjava/util/concurrent/TimeUnit;)Lio/reactivex/disposables/Disposable;
  39. move-result-object p1
  40. return-object p1
  41. .end method