.class public final Lrx/observers/c; .super Ljava/lang/Object; .source "SerializedObserver.java" # interfaces .implements Lrx/e; # annotations .annotation system Ldalvik/annotation/MemberClasses; value = { Lrx/observers/c$a; } .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lrx/e<", "TT;>;" } .end annotation # instance fields .field private final bQu:Lrx/e; .annotation system Ldalvik/annotation/Signature; value = { "Lrx/e<", "-TT;>;" } .end annotation .end field .field private bQv:Lrx/observers/c$a; .field private emitting:Z .field private volatile terminated:Z # direct methods .method public constructor (Lrx/e;)V .locals 0 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lrx/e<", "-TT;>;)V" } .end annotation invoke-direct {p0}, Ljava/lang/Object;->()V iput-object p1, p0, Lrx/observers/c;->bQu:Lrx/e; return-void .end method # virtual methods .method public final onCompleted()V .locals 2 iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_0 return-void :cond_0 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_1 monitor-exit p0 return-void :cond_1 const/4 v0, 0x1 iput-boolean v0, p0, Lrx/observers/c;->terminated:Z iget-boolean v1, p0, Lrx/observers/c;->emitting:Z if-eqz v1, :cond_3 iget-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; if-nez v0, :cond_2 new-instance v0, Lrx/observers/c$a; invoke-direct {v0}, Lrx/observers/c$a;->()V iput-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; :cond_2 invoke-static {}, Lrx/internal/a/g;->Ks()Ljava/lang/Object; move-result-object v1 invoke-virtual {v0, v1}, Lrx/observers/c$a;->add(Ljava/lang/Object;)V monitor-exit p0 return-void :cond_3 iput-boolean v0, p0, Lrx/observers/c;->emitting:Z monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 iget-object v0, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-interface {v0}, Lrx/e;->onCompleted()V return-void :catchall_0 move-exception v0 :try_start_1 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw v0 .end method .method public final onError(Ljava/lang/Throwable;)V .locals 2 invoke-static {p1}, Lrx/a/b;->I(Ljava/lang/Throwable;)V iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_0 return-void :cond_0 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_1 monitor-exit p0 return-void :cond_1 const/4 v0, 0x1 iput-boolean v0, p0, Lrx/observers/c;->terminated:Z iget-boolean v1, p0, Lrx/observers/c;->emitting:Z if-eqz v1, :cond_3 iget-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; if-nez v0, :cond_2 new-instance v0, Lrx/observers/c$a; invoke-direct {v0}, Lrx/observers/c$a;->()V iput-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; :cond_2 invoke-static {p1}, Lrx/internal/a/g;->K(Ljava/lang/Throwable;)Ljava/lang/Object; move-result-object p1 invoke-virtual {v0, p1}, Lrx/observers/c$a;->add(Ljava/lang/Object;)V monitor-exit p0 return-void :cond_3 iput-boolean v0, p0, Lrx/observers/c;->emitting:Z monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 iget-object v0, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-interface {v0, p1}, Lrx/e;->onError(Ljava/lang/Throwable;)V return-void :catchall_0 move-exception p1 :try_start_1 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw p1 .end method .method public final onNext(Ljava/lang/Object;)V .locals 6 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)V" } .end annotation iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_0 return-void :cond_0 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/observers/c;->terminated:Z if-eqz v0, :cond_1 monitor-exit p0 return-void :cond_1 iget-boolean v0, p0, Lrx/observers/c;->emitting:Z if-eqz v0, :cond_3 iget-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; if-nez v0, :cond_2 new-instance v0, Lrx/observers/c$a; invoke-direct {v0}, Lrx/observers/c$a;->()V iput-object v0, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; :cond_2 invoke-static {p1}, Lrx/internal/a/g;->bJ(Ljava/lang/Object;)Ljava/lang/Object; move-result-object p1 invoke-virtual {v0, p1}, Lrx/observers/c$a;->add(Ljava/lang/Object;)V monitor-exit p0 return-void :cond_3 const/4 v0, 0x1 iput-boolean v0, p0, Lrx/observers/c;->emitting:Z monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_3 :try_start_1 iget-object v1, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-interface {v1, p1}, Lrx/e;->onNext(Ljava/lang/Object;)V :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_2 :cond_4 monitor-enter p0 :try_start_2 iget-object v1, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; const/4 v2, 0x0 if-nez v1, :cond_5 iput-boolean v2, p0, Lrx/observers/c;->emitting:Z monitor-exit p0 return-void :cond_5 const/4 v3, 0x0 iput-object v3, p0, Lrx/observers/c;->bQv:Lrx/observers/c$a; monitor-exit p0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 iget-object v1, v1, Lrx/observers/c$a;->array:[Ljava/lang/Object; array-length v3, v1 :goto_0 if-ge v2, v3, :cond_4 aget-object v4, v1, v2 if-eqz v4, :cond_4 :try_start_3 iget-object v5, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-static {v5, v4}, Lrx/internal/a/g;->a(Lrx/e;Ljava/lang/Object;)Z move-result v4 if-eqz v4, :cond_6 iput-boolean v0, p0, Lrx/observers/c;->terminated:Z :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_0 return-void :cond_6 add-int/lit8 v2, v2, 0x1 goto :goto_0 :catchall_0 move-exception v1 iput-boolean v0, p0, Lrx/observers/c;->terminated:Z invoke-static {v1}, Lrx/a/b;->I(Ljava/lang/Throwable;)V iget-object v0, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-static {v1, p1}, Lrx/a/g;->a(Ljava/lang/Throwable;Ljava/lang/Object;)Ljava/lang/Throwable; move-result-object p1 invoke-interface {v0, p1}, Lrx/e;->onError(Ljava/lang/Throwable;)V return-void :catchall_1 move-exception p1 :try_start_4 monitor-exit p0 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_1 throw p1 :catchall_2 move-exception v1 iput-boolean v0, p0, Lrx/observers/c;->terminated:Z iget-object v0, p0, Lrx/observers/c;->bQu:Lrx/e; invoke-static {v1, v0, p1}, Lrx/a/b;->a(Ljava/lang/Throwable;Lrx/e;Ljava/lang/Object;)V return-void :catchall_3 move-exception p1 :try_start_5 monitor-exit p0 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_3 goto :goto_2 :goto_1 throw p1 :goto_2 goto :goto_1 .end method