package j0.l.a;

import androidx.recyclerview.widget.RecyclerView;
import b.i.a.f.e.o.f;
import j0.l.a.q;
import j0.l.e.d;
import j0.l.e.i;
import j0.l.e.n.c;
import j0.l.e.n.e;
import j0.l.e.o.y;
import j0.o.l;
import java.util.Iterator;
import java.util.Queue;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.atomic.AtomicReference;
import rx.Observable;
import rx.Subscriber;
import rx.exceptions.MissingBackpressureException;
/* compiled from: OnSubscribeFlattenIterable */
public final class n<T, R> implements Observable.a<R> {
    public final Observable<? extends T> j;
    public final j0.k.b<? super T, ? extends Iterable<? extends R>> k;
    public final int l;

    /* compiled from: OnSubscribeFlattenIterable */
    public static final class a<T, R> extends Subscriber<T> {
        public final Subscriber<? super R> j;
        public final j0.k.b<? super T, ? extends Iterable<? extends R>> k;
        public final long l;
        public final Queue<Object> m;
        public final AtomicReference<Throwable> n = new AtomicReference<>();
        public final AtomicLong o = new AtomicLong();
        public final AtomicInteger p = new AtomicInteger();
        public volatile boolean q;
        public long r;

        /* renamed from: s  reason: collision with root package name */
        public Iterator<? extends R> f3755s;

        public a(Subscriber<? super R> subscriber, j0.k.b<? super T, ? extends Iterable<? extends R>> bVar, int i) {
            this.j = subscriber;
            this.k = bVar;
            if (i == Integer.MAX_VALUE) {
                this.l = RecyclerView.FOREVER_NS;
                this.m = new e(i.j);
            } else {
                this.l = (long) (i - (i >> 2));
                if (y.b()) {
                    this.m = new j0.l.e.o.n(i);
                } else {
                    this.m = new c(i);
                }
            }
            request((long) i);
        }

        public boolean a(boolean z2, boolean z3, Subscriber<?> subscriber, Queue<?> queue) {
            if (subscriber.isUnsubscribed()) {
                queue.clear();
                this.f3755s = null;
                return true;
            } else if (!z2) {
                return false;
            } else {
                if (this.n.get() != null) {
                    Throwable h = d.h(this.n);
                    unsubscribe();
                    queue.clear();
                    this.f3755s = null;
                    subscriber.onError(h);
                    return true;
                } else if (!z3) {
                    return false;
                } else {
                    subscriber.onCompleted();
                    return true;
                }
            }
        }

        /* JADX WARNING: Removed duplicated region for block: B:26:0x0066  */
        /* JADX WARNING: Removed duplicated region for block: B:49:0x00af  */
        /* JADX WARNING: Removed duplicated region for block: B:58:0x00c5  */
        /* JADX WARNING: Removed duplicated region for block: B:67:0x00cf A[SYNTHETIC] */
        /* JADX WARNING: Removed duplicated region for block: B:68:0x00cf A[SYNTHETIC] */
        /* JADX WARNING: Removed duplicated region for block: B:70:0x00cc A[SYNTHETIC] */
        /* JADX WARNING: Removed duplicated region for block: B:72:0x00d8 A[SYNTHETIC] */
        /* JADX WARNING: Removed duplicated region for block: B:75:0x0010 A[SYNTHETIC] */
        public void b() {
            Iterator<? extends R> it;
            int i;
            long j;
            long j2;
            if (this.p.getAndIncrement() == 0) {
                Subscriber<? super R> subscriber = this.j;
                Queue<?> queue = this.m;
                int i2 = 1;
                while (true) {
                    it = this.f3755s;
                    boolean z2 = false;
                    if (it == null) {
                        boolean z3 = this.q;
                        Object poll = queue.poll();
                        boolean z4 = poll == null;
                        if (!a(z3, z4, subscriber, queue)) {
                            if (!z4) {
                                long j3 = this.r + 1;
                                i = i2;
                                if (j3 == this.l) {
                                    this.r = 0;
                                    request(j3);
                                } else {
                                    this.r = j3;
                                }
                                try {
                                    it = ((Iterable) this.k.call((Object) e.b(poll))).iterator();
                                    if (!it.hasNext()) {
                                        i2 = i;
                                    } else {
                                        this.f3755s = it;
                                        if (it == null) {
                                            j = this.o.get();
                                            j2 = 0;
                                            while (true) {
                                                if (j2 == j) {
                                                    break;
                                                } else if (!a(this.q, false, subscriber, queue)) {
                                                    try {
                                                        subscriber.onNext((Object) it.next());
                                                        if (!a(this.q, false, subscriber, queue)) {
                                                            j2++;
                                                            try {
                                                                if (!it.hasNext()) {
                                                                    this.f3755s = null;
                                                                    break;
                                                                }
                                                            } catch (Throwable th) {
                                                                f.o1(th);
                                                                this.f3755s = null;
                                                                onError(th);
                                                            }
                                                        } else {
                                                            return;
                                                        }
                                                    } catch (Throwable th2) {
                                                        f.o1(th2);
                                                        this.f3755s = null;
                                                        onError(th2);
                                                    }
                                                } else {
                                                    return;
                                                }
                                            }
                                            if (j2 == j) {
                                                boolean z5 = this.q;
                                                if (queue.isEmpty() && it == null) {
                                                    z2 = true;
                                                }
                                                if (a(z5, z2, subscriber, queue)) {
                                                    return;
                                                }
                                            }
                                            if (j2 != 0) {
                                                f.U0(this.o, j2);
                                            }
                                            if (it != null) {
                                                i2 = i;
                                            }
                                        }
                                        i2 = this.p.addAndGet(-i);
                                        if (i2 != 0) {
                                            return;
                                        }
                                    }
                                } catch (Throwable th3) {
                                    f.o1(th3);
                                    onError(th3);
                                }
                            }
                        } else {
                            return;
                        }
                    }
                    i = i2;
                    if (it == null) {
                    }
                    i2 = this.p.addAndGet(-i);
                    if (i2 != 0) {
                    }
                }
            } else {
                return;
            }
            it = null;
            if (j2 == j) {
            }
            if (j2 != 0) {
            }
            if (it != null) {
            }
        }

        @Override // j0.g
        public void onCompleted() {
            this.q = true;
            b();
        }

        @Override // j0.g
        public void onError(Throwable th) {
            if (d.f(this.n, th)) {
                this.q = true;
                b();
                return;
            }
            l.b(th);
        }

        @Override // j0.g
        public void onNext(T t) {
            Queue<Object> queue = this.m;
            if (t == null) {
                t = (T) e.f3749b;
            }
            if (!queue.offer(t)) {
                unsubscribe();
                onError(new MissingBackpressureException());
                return;
            }
            b();
        }
    }

    /* compiled from: OnSubscribeFlattenIterable */
    public static final class b<T, R> implements Observable.a<R> {
        public final T j;
        public final j0.k.b<? super T, ? extends Iterable<? extends R>> k;

        public b(T t, j0.k.b<? super T, ? extends Iterable<? extends R>> bVar) {
            this.j = t;
            this.k = bVar;
        }

        @Override // rx.functions.Action1
        public void call(Object obj) {
            Subscriber subscriber = (Subscriber) obj;
            try {
                Iterator<T> it = ((Iterable) this.k.call(this.j)).iterator();
                if (!it.hasNext()) {
                    subscriber.onCompleted();
                } else {
                    subscriber.setProducer(new q.a(subscriber, it));
                }
            } catch (Throwable th) {
                f.p1(th, subscriber, this.j);
            }
        }
    }

    public n(Observable<? extends T> observable, j0.k.b<? super T, ? extends Iterable<? extends R>> bVar, int i) {
        this.j = observable;
        this.k = bVar;
        this.l = i;
    }

    @Override // rx.functions.Action1
    public void call(Object obj) {
        Subscriber subscriber = (Subscriber) obj;
        a aVar = new a(subscriber, this.k, this.l);
        subscriber.add(aVar);
        subscriber.setProducer(new m(this, aVar));
        this.j.i0(aVar);
    }
}