QueueDrainSubscriberWip.smali 749 B

12345678910111213141516171819202122232425
  1. .class Lio/reactivex/internal/subscribers/QueueDrainSubscriberWip;
  2. .super Lio/reactivex/internal/subscribers/QueueDrainSubscriberPad0;
  3. .source "QueueDrainSubscriber.java"
  4. # instance fields
  5. .field final wip:Ljava/util/concurrent/atomic/AtomicInteger;
  6. # direct methods
  7. .method constructor <init>()V
  8. .locals 1
  9. .line 179
  10. invoke-direct {p0}, Lio/reactivex/internal/subscribers/QueueDrainSubscriberPad0;-><init>()V
  11. .line 180
  12. new-instance v0, Ljava/util/concurrent/atomic/AtomicInteger;
  13. invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicInteger;-><init>()V
  14. iput-object v0, p0, Lio/reactivex/internal/subscribers/QueueDrainSubscriberWip;->wip:Ljava/util/concurrent/atomic/AtomicInteger;
  15. return-void
  16. .end method