.class public final Lrx/subscriptions/CompositeSubscription; .super Ljava/lang/Object; # interfaces .implements Lrx/Subscription; # instance fields .field private volatile cnf:Z .field private cvO:Ljava/util/Set; .annotation system Ldalvik/annotation/Signature; value = { "Ljava/util/Set<", "Lrx/Subscription;", ">;" } .end annotation .end field # direct methods .method public constructor ()V .locals 0 invoke-direct {p0}, Ljava/lang/Object;->()V return-void .end method .method public varargs constructor ([Lrx/Subscription;)V .locals 1 invoke-direct {p0}, Ljava/lang/Object;->()V new-instance v0, Ljava/util/HashSet; invoke-static {p1}, Ljava/util/Arrays;->asList([Ljava/lang/Object;)Ljava/util/List; move-result-object p1 invoke-direct {v0, p1}, Ljava/util/HashSet;->(Ljava/util/Collection;)V iput-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; return-void .end method .method private static m(Ljava/util/Collection;)V .locals 2 .annotation system Ldalvik/annotation/Signature; value = { "(", "Ljava/util/Collection<", "Lrx/Subscription;", ">;)V" } .end annotation if-nez p0, :cond_0 return-void :cond_0 const/4 v0, 0x0 invoke-interface {p0}, Ljava/util/Collection;->iterator()Ljava/util/Iterator; move-result-object p0 :goto_0 invoke-interface {p0}, Ljava/util/Iterator;->hasNext()Z move-result v1 if-eqz v1, :cond_2 invoke-interface {p0}, Ljava/util/Iterator;->next()Ljava/lang/Object; move-result-object v1 check-cast v1, Lrx/Subscription; :try_start_0 invoke-interface {v1}, Lrx/Subscription;->unsubscribe()V :try_end_0 .catch Ljava/lang/Throwable; {:try_start_0 .. :try_end_0} :catch_0 goto :goto_0 :catch_0 move-exception v1 if-nez v0, :cond_1 new-instance v0, Ljava/util/ArrayList; invoke-direct {v0}, Ljava/util/ArrayList;->()V :cond_1 invoke-interface {v0, v1}, Ljava/util/List;->add(Ljava/lang/Object;)Z goto :goto_0 :cond_2 invoke-static {v0}, Lrx/a/b;->az(Ljava/util/List;)V return-void .end method # virtual methods .method public final add(Lrx/Subscription;)V .locals 2 invoke-interface {p1}, Lrx/Subscription;->isUnsubscribed()Z move-result v0 if-eqz v0, :cond_0 return-void :cond_0 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_3 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_2 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; if-nez v0, :cond_1 new-instance v0, Ljava/util/HashSet; const/4 v1, 0x4 invoke-direct {v0, v1}, Ljava/util/HashSet;->(I)V iput-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; :cond_1 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; invoke-interface {v0, p1}, Ljava/util/Set;->add(Ljava/lang/Object;)Z monitor-exit p0 return-void :cond_2 monitor-exit p0 goto :goto_0 :catchall_0 move-exception p1 monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 throw p1 :cond_3 :goto_0 invoke-interface {p1}, Lrx/Subscription;->unsubscribe()V return-void .end method .method public final clear()V .locals 2 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_2 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_1 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; if-nez v0, :cond_0 goto :goto_0 :cond_0 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; const/4 v1, 0x0 iput-object v1, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 invoke-static {v0}, Lrx/subscriptions/CompositeSubscription;->m(Ljava/util/Collection;)V goto :goto_1 :cond_1 :goto_0 :try_start_1 monitor-exit p0 return-void :catchall_0 move-exception v0 monitor-exit p0 :try_end_1 .catchall {:try_start_1 .. :try_end_1} :catchall_0 throw v0 :cond_2 :goto_1 return-void .end method .method public final e(Lrx/Subscription;)V .locals 1 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_2 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_1 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; if-nez v0, :cond_0 goto :goto_0 :cond_0 iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; invoke-interface {v0, p1}, Ljava/util/Set;->remove(Ljava/lang/Object;)Z move-result v0 monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 if-eqz v0, :cond_2 invoke-interface {p1}, Lrx/Subscription;->unsubscribe()V goto :goto_1 :cond_1 :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 :cond_2 :goto_1 return-void .end method .method public final isUnsubscribed()Z .locals 1 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z return v0 .end method .method public final unsubscribe()V .locals 2 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-nez v0, :cond_1 monitor-enter p0 :try_start_0 iget-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z if-eqz v0, :cond_0 monitor-exit p0 return-void :cond_0 const/4 v0, 0x1 iput-boolean v0, p0, Lrx/subscriptions/CompositeSubscription;->cnf:Z iget-object v0, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; const/4 v1, 0x0 iput-object v1, p0, Lrx/subscriptions/CompositeSubscription;->cvO:Ljava/util/Set; monitor-exit p0 :try_end_0 .catchall {:try_start_0 .. :try_end_0} :catchall_0 invoke-static {v0}, Lrx/subscriptions/CompositeSubscription;->m(Ljava/util/Collection;)V goto :goto_0 :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 :cond_1 :goto_0 return-void .end method