.class public final Lrx/b/a; .super Ljava/lang/Object; .source "BlockingObservable.java" # annotations .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;" } .end annotation # static fields .field static final bQb:Ljava/lang/Object; .field static final bQc:Ljava/lang/Object; .field static final bQd:Ljava/lang/Object; # instance fields .field public final bQa:Lrx/Observable; .annotation system Ldalvik/annotation/Signature; value = { "Lrx/Observable<", "+TT;>;" } .end annotation .end field # direct methods .method static constructor ()V .locals 1 new-instance v0, Ljava/lang/Object; invoke-direct {v0}, Ljava/lang/Object;->()V sput-object v0, Lrx/b/a;->bQb:Ljava/lang/Object; new-instance v0, Ljava/lang/Object; invoke-direct {v0}, Ljava/lang/Object;->()V sput-object v0, Lrx/b/a;->bQc:Ljava/lang/Object; new-instance v0, Ljava/lang/Object; invoke-direct {v0}, Ljava/lang/Object;->()V sput-object v0, Lrx/b/a;->bQd:Ljava/lang/Object; return-void .end method .method private constructor (Lrx/Observable;)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lrx/Observable<", "+TT;>;)V" } .end annotation invoke-direct {p0}, Ljava/lang/Object;->()V iput-object p1, p0, Lrx/b/a;->bQa:Lrx/Observable; return-void .end method .method public static g(Lrx/Observable;)Lrx/b/a; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lrx/Observable<", "+TT;>;)", "Lrx/b/a<", "TT;>;" } .end annotation new-instance v0, Lrx/b/a; invoke-direct {v0, p0}, Lrx/b/a;->(Lrx/Observable;)V return-object v0 .end method .method private h(Lrx/Observable;)Ljava/lang/Object; .locals 4 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lrx/Observable<", "+TT;>;)TT;" } .end annotation new-instance v0, Ljava/util/concurrent/atomic/AtomicReference; invoke-direct {v0}, Ljava/util/concurrent/atomic/AtomicReference;->()V new-instance v1, Ljava/util/concurrent/atomic/AtomicReference; invoke-direct {v1}, Ljava/util/concurrent/atomic/AtomicReference;->()V new-instance v2, Ljava/util/concurrent/CountDownLatch; const/4 v3, 0x1 invoke-direct {v2, v3}, Ljava/util/concurrent/CountDownLatch;->(I)V new-instance v3, Lrx/b/a$1; invoke-direct {v3, p0, v2, v1, v0}, Lrx/b/a$1;->(Lrx/b/a;Ljava/util/concurrent/CountDownLatch;Ljava/util/concurrent/atomic/AtomicReference;Ljava/util/concurrent/atomic/AtomicReference;)V invoke-static {v3, p1}, Lrx/Observable;->a(Lrx/Subscriber;Lrx/Observable;)Lrx/Subscription; move-result-object p1 invoke-static {v2, p1}, Lrx/internal/util/d;->a(Ljava/util/concurrent/CountDownLatch;Lrx/Subscription;)V invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object p1 if-eqz p1, :cond_0 invoke-virtual {v1}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object p1 check-cast p1, Ljava/lang/Throwable; invoke-static {p1}, Lrx/a/b;->d(Ljava/lang/Throwable;)Ljava/lang/RuntimeException; :cond_0 invoke-virtual {v0}, Ljava/util/concurrent/atomic/AtomicReference;->get()Ljava/lang/Object; move-result-object p1 return-object p1 .end method # virtual methods .method public final Ld()Ljava/lang/Object; .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "()TT;" } .end annotation iget-object v0, p0, Lrx/b/a;->bQa:Lrx/Observable; invoke-virtual {v0}, Lrx/Observable;->JU()Lrx/Observable; move-result-object v0 invoke-direct {p0, v0}, Lrx/b/a;->h(Lrx/Observable;)Ljava/lang/Object; move-result-object v0 return-object v0 .end method