discord-jadx/app/src/main/java/rx/internal/util/SubscriptionList.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;
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() {
        List<Subscription> list;
        ArrayList arrayList;
        if (!this.k) {
            synchronized (this) {
                if (!this.k) {
                    this.k = true;
                    list = this.j;
                    arrayList = null;
                    this.j = null;
                } else {
                    return;
                }
            }
            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);
            }
        }
    }
}