apkfuckery/com.discord/smali_classes2/rx/b/a$1.smali
2019-08-17 10:22:04 +02:00

90 lines
2.4 KiB
Smali

.class final Lrx/b/a$1;
.super Lrx/Subscriber;
.source "BlockingObservable.java"
# annotations
.annotation system Ldalvik/annotation/EnclosingMethod;
value = Lrx/b/a;->h(Lrx/Observable;)Ljava/lang/Object;
.end annotation
.annotation system Ldalvik/annotation/InnerClass;
accessFlags = 0x0
name = null
.end annotation
.annotation system Ldalvik/annotation/Signature;
value = {
"Lrx/Subscriber<",
"TT;>;"
}
.end annotation
# instance fields
.field final synthetic bQr:Ljava/util/concurrent/atomic/AtomicReference;
.field final synthetic bQs:Ljava/util/concurrent/atomic/AtomicReference;
.field final synthetic bQt:Lrx/b/a;
.field final synthetic val$latch:Ljava/util/concurrent/CountDownLatch;
# direct methods
.method constructor <init>(Lrx/b/a;Ljava/util/concurrent/CountDownLatch;Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/atomic/AtomicReference;)V
.locals 0
iput-object p1, p0, Lrx/b/a$1;->bQt:Lrx/b/a;
iput-object p2, p0, Lrx/b/a$1;->val$latch:Ljava/util/concurrent/CountDownLatch;
iput-object p3, p0, Lrx/b/a$1;->bQr:Ljava/util/concurrent/atomic/AtomicReference;
iput-object p4, p0, Lrx/b/a$1;->bQs:Ljava/util/concurrent/atomic/AtomicReference;
invoke-direct {p0}, Lrx/Subscriber;-><init>()V
return-void
.end method
# virtual methods
.method public final onCompleted()V
.locals 1
iget-object v0, p0, Lrx/b/a$1;->val$latch:Ljava/util/concurrent/CountDownLatch;
invoke-virtual {v0}, Ljava/util/concurrent/CountDownLatch;->countDown()V
return-void
.end method
.method public final onError(Ljava/lang/Throwable;)V
.locals 1
iget-object v0, p0, Lrx/b/a$1;->bQr:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->set(Ljava/lang/Object;)V
iget-object p1, p0, Lrx/b/a$1;->val$latch:Ljava/util/concurrent/CountDownLatch;
invoke-virtual {p1}, Ljava/util/concurrent/CountDownLatch;->countDown()V
return-void
.end method
.method public final onNext(Ljava/lang/Object;)V
.locals 1
.annotation system Ldalvik/annotation/Signature;
value = {
"(TT;)V"
}
.end annotation
iget-object v0, p0, Lrx/b/a$1;->bQs:Ljava/util/concurrent/atomic/AtomicReference;
invoke-virtual {v0, p1}, Ljava/util/concurrent/atomic/AtomicReference;->set(Ljava/lang/Object;)V
return-void
.end method