78 lines
2.3 KiB
Java
78 lines
2.3 KiB
Java
package rx.internal.util;
|
|
|
|
import b.i.a.f.e.o.f;
|
|
import java.util.ArrayList;
|
|
import java.util.Arrays;
|
|
import java.util.LinkedList;
|
|
import java.util.List;
|
|
import rx.Subscription;
|
|
/* loaded from: classes3.dex */
|
|
public final class SubscriptionList implements Subscription {
|
|
public List<Subscription> j;
|
|
public volatile boolean k;
|
|
|
|
public SubscriptionList() {
|
|
}
|
|
|
|
public SubscriptionList(Subscription subscription) {
|
|
LinkedList linkedList = new LinkedList();
|
|
this.j = linkedList;
|
|
linkedList.add(subscription);
|
|
}
|
|
|
|
public SubscriptionList(Subscription... subscriptionArr) {
|
|
this.j = new LinkedList(Arrays.asList(subscriptionArr));
|
|
}
|
|
|
|
public void a(Subscription subscription) {
|
|
if (!subscription.isUnsubscribed()) {
|
|
if (!this.k) {
|
|
synchronized (this) {
|
|
if (!this.k) {
|
|
List list = this.j;
|
|
if (list == null) {
|
|
list = new LinkedList();
|
|
this.j = list;
|
|
}
|
|
list.add(subscription);
|
|
return;
|
|
}
|
|
}
|
|
}
|
|
subscription.unsubscribe();
|
|
}
|
|
}
|
|
|
|
@Override // rx.Subscription
|
|
public boolean isUnsubscribed() {
|
|
return this.k;
|
|
}
|
|
|
|
@Override // rx.Subscription
|
|
public void unsubscribe() {
|
|
if (!this.k) {
|
|
synchronized (this) {
|
|
if (!this.k) {
|
|
this.k = true;
|
|
List<Subscription> list = this.j;
|
|
ArrayList arrayList = null;
|
|
this.j = null;
|
|
if (list != null) {
|
|
for (Subscription subscription : list) {
|
|
try {
|
|
subscription.unsubscribe();
|
|
} catch (Throwable th) {
|
|
if (arrayList == null) {
|
|
arrayList = new ArrayList();
|
|
}
|
|
arrayList.add(th);
|
|
}
|
|
}
|
|
f.n1(arrayList);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|