.class public final Lb0/r/b$c; .super Ljava/lang/Object; .source "SubjectSubscriptionManager.java" # interfaces .implements Lb0/g; # annotations .annotation system Ldalvik/annotation/EnclosingClass; value = Lb0/r/b; .end annotation .annotation system Ldalvik/annotation/InnerClass; accessFlags = 0x19 name = "c" .end annotation .annotation system Ldalvik/annotation/Signature; value = { "", "Ljava/lang/Object;", "Lb0/g<", "TT;>;" } .end annotation # instance fields .field public final d:Lrx/Subscriber; .annotation system Ldalvik/annotation/Signature; value = { "Lrx/Subscriber<", "-TT;>;" } .end annotation .end field .field public e:Z .field public f:Z .field public g:Ljava/util/List; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/List<", "Ljava/lang/Object;", ">;" } .end annotation .end field .field public h:Z # direct methods .method public constructor (Lrx/Subscriber;)V .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(", "Lrx/Subscriber<", "-TT;>;)V" } .end annotation invoke-direct {p0}, Ljava/lang/Object;->()V const/4 v0, 0x1 iput-boolean v0, p0, Lb0/r/b$c;->e:Z iput-object p1, p0, Lb0/r/b$c;->d:Lrx/Subscriber; return-void .end method # virtual methods .method public a(Ljava/lang/Object;)V .locals 1 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lb0/r/b$c;->e:Z if-eqz v0, :cond_3 iget-boolean v0, p0, Lb0/r/b$c;->f:Z if-eqz v0, :cond_0 goto :goto_0 :cond_0 const/4 v0, 0x0 iput-boolean v0, p0, Lb0/r/b$c;->e:Z if-eqz p1, :cond_1 const/4 v0, 0x1 :cond_1 iput-boolean v0, p0, Lb0/r/b$c;->f:Z monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 if-eqz p1, :cond_2 const/4 v0, 0x0 invoke-virtual {p0, v0, p1}, Lb0/r/b$c;->a(Ljava/util/List;Ljava/lang/Object;)V :cond_2 return-void :cond_3 :goto_0 :try_start_1 monitor-exit p0 return-void :catchall_0 move-exception p1 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw p1 .end method .method public a(Ljava/util/List;Ljava/lang/Object;)V .locals 5 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/List<", "Ljava/lang/Object;", ">;", "Ljava/lang/Object;", ")V" } .end annotation const/4 v0, 0x1 const/4 v1, 0x1 :goto_0 const/4 v2, 0x0 if-eqz p1, :cond_1 :try_start_0 invoke-interface {p1}, Ljava/util/List;->iterator()Ljava/util/Iterator; move-result-object p1 :cond_0 :goto_1 invoke-interface {p1}, Ljava/util/Iterator;->hasNext()Z move-result v3 if-eqz v3, :cond_1 invoke-interface {p1}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v3 if-eqz v3, :cond_0 iget-object v4, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-static {v4, v3}, Lb0/m/a/h;->a(Lb0/g;Ljava/lang/Object;)Z goto :goto_1 :catchall_0 move-exception p1 move-object p2, p1 goto :goto_4 :cond_1 if-eqz v1, :cond_3 if-eqz p2, :cond_2 iget-object p1, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-static {p1, p2}, Lb0/m/a/h;->a(Lb0/g;Ljava/lang/Object;)Z :cond_2 const/4 v1, 0x0 :cond_3 monitor-enter p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 :try_start_1 iget-object p1, p0, Lb0/r/b$c;->g:Ljava/util/List; const/4 v3, 0x0 iput-object v3, p0, Lb0/r/b$c;->g:Ljava/util/List; if-nez p1, :cond_4 iput-boolean v2, p0, Lb0/r/b$c;->f:Z :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_2 :try_start_2 monitor-exit p0 :try_end_2 .catchall {:try_start_2 .. :try_end_2} :catchall_1 return-void :catchall_1 move-exception p1 goto :goto_2 :cond_4 :try_start_3 monitor-exit p0 :try_end_3 .catchall {:try_start_3 .. :try_end_3} :catchall_2 goto :goto_0 :catchall_2 move-exception p1 const/4 v0, 0x0 :goto_2 move-object p2, p1 move-object p1, p0 :goto_3 :try_start_4 monitor-exit p1 :try_end_4 .catchall {:try_start_4 .. :try_end_4} :catchall_4 :try_start_5 throw p2 :try_end_5 .catchall {:try_start_5 .. :try_end_5} :catchall_3 :catchall_3 move-exception p2 goto :goto_5 :catchall_4 move-exception p2 goto :goto_3 :goto_4 move-object p1, p0 const/4 v0, 0x0 :goto_5 if-nez v0, :cond_5 monitor-enter p1 :try_start_6 iput-boolean v2, p1, Lb0/r/b$c;->f:Z monitor-exit p1 goto :goto_6 :catchall_5 move-exception p2 monitor-exit p1 :try_end_6 .catchall {:try_start_6 .. :try_end_6} :catchall_5 throw p2 :cond_5 :goto_6 throw p2 .end method .method public b(Ljava/lang/Object;)V .locals 1 iget-boolean v0, p0, Lb0/r/b$c;->h:Z if-nez v0, :cond_2 monitor-enter p0 const/4 v0, 0x0 :try_start_0 iput-boolean v0, p0, Lb0/r/b$c;->e:Z iget-boolean v0, p0, Lb0/r/b$c;->f:Z if-eqz v0, :cond_1 iget-object v0, p0, Lb0/r/b$c;->g:Ljava/util/List; if-nez v0, :cond_0 new-instance v0, Ljava/util/ArrayList; invoke-direct {v0}, Ljava/util/ArrayList;->()V iput-object v0, p0, Lb0/r/b$c;->g:Ljava/util/List; :cond_0 iget-object v0, p0, Lb0/r/b$c;->g:Ljava/util/List; invoke-interface {v0, p1}, Ljava/util/List;->add(Ljava/lang/Object;)Z monitor-exit p0 return-void :cond_1 monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 const/4 v0, 0x1 iput-boolean v0, p0, Lb0/r/b$c;->h:Z goto :goto_0 :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 :cond_2 :goto_0 iget-object v0, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-static {v0, p1}, Lb0/m/a/h;->a(Lb0/g;Ljava/lang/Object;)Z return-void .end method .method public onCompleted()V .locals 1 iget-object v0, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-interface {v0}, Lb0/g;->onCompleted()V return-void .end method .method public onError(Ljava/lang/Throwable;)V .locals 1 iget-object v0, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-interface {v0, p1}, Lb0/g;->onError(Ljava/lang/Throwable;)V return-void .end method .method public onNext(Ljava/lang/Object;)V .locals 1 .annotation system Ldalvik/annotation/Signature; value = { "(TT;)V" } .end annotation iget-object v0, p0, Lb0/r/b$c;->d:Lrx/Subscriber; invoke-interface {v0, p1}, Lb0/g;->onNext(Ljava/lang/Object;)V return-void .end method