149 lines
5.2 KiB
Java
149 lines
5.2 KiB
Java
package j0.l.a;
|
|
|
|
import androidx.recyclerview.widget.RecyclerView;
|
|
import j0.a;
|
|
import j0.l.e.c;
|
|
import java.util.concurrent.ConcurrentLinkedQueue;
|
|
import java.util.concurrent.atomic.AtomicBoolean;
|
|
import java.util.concurrent.atomic.AtomicLong;
|
|
import rx.Observable;
|
|
import rx.Subscriber;
|
|
import rx.exceptions.MissingBackpressureException;
|
|
import rx.functions.Action0;
|
|
/* compiled from: OperatorOnBackpressureBuffer */
|
|
public class a1<T> implements Observable.b<T, T> {
|
|
public final a.b j = a.C0323a.a;
|
|
|
|
/* compiled from: OperatorOnBackpressureBuffer */
|
|
public static final class a<T> extends Subscriber<T> implements c.a {
|
|
public final ConcurrentLinkedQueue<Object> j = new ConcurrentLinkedQueue<>();
|
|
public final AtomicLong k;
|
|
public final Subscriber<? super T> l;
|
|
public final AtomicBoolean m = new AtomicBoolean(false);
|
|
public final c n;
|
|
public final Action0 o;
|
|
public final a.b p;
|
|
|
|
public a(Subscriber<? super T> subscriber, Long l, Action0 action0, a.b bVar) {
|
|
this.l = subscriber;
|
|
this.k = null;
|
|
this.o = null;
|
|
this.n = new c(this);
|
|
this.p = bVar;
|
|
}
|
|
|
|
@Override // j0.g
|
|
public void onCompleted() {
|
|
if (!this.m.get()) {
|
|
c cVar = this.n;
|
|
cVar.terminated = true;
|
|
cVar.a();
|
|
}
|
|
}
|
|
|
|
@Override // j0.g
|
|
public void onError(Throwable th) {
|
|
if (!this.m.get()) {
|
|
c cVar = this.n;
|
|
if (!cVar.terminated) {
|
|
cVar.exception = th;
|
|
cVar.terminated = true;
|
|
cVar.a();
|
|
}
|
|
}
|
|
}
|
|
|
|
/* JADX WARNING: Removed duplicated region for block: B:21:0x0045 A[SYNTHETIC, Splitter:B:21:0x0045] */
|
|
/* JADX WARNING: Removed duplicated region for block: B:38:0x006b A[EDGE_INSN: B:38:0x006b->B:30:0x006b ?: BREAK , SYNTHETIC] */
|
|
@Override // j0.g
|
|
public void onNext(T t) {
|
|
boolean z2;
|
|
Action0 action0;
|
|
boolean z3 = false;
|
|
if (this.k != null) {
|
|
while (true) {
|
|
long j = this.k.get();
|
|
if (j <= 0) {
|
|
try {
|
|
if (this.p.a()) {
|
|
Object poll = this.j.poll();
|
|
AtomicLong atomicLong = this.k;
|
|
if (!(atomicLong == null || poll == null)) {
|
|
atomicLong.incrementAndGet();
|
|
}
|
|
if (poll != null) {
|
|
z2 = true;
|
|
action0 = this.o;
|
|
if (action0 != null) {
|
|
try {
|
|
action0.call();
|
|
} catch (Throwable th) {
|
|
h0.b.a.f.a.i(th);
|
|
c cVar = this.n;
|
|
if (!cVar.terminated) {
|
|
cVar.exception = th;
|
|
cVar.terminated = true;
|
|
cVar.a();
|
|
}
|
|
}
|
|
}
|
|
if (!z2) {
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
} catch (MissingBackpressureException e) {
|
|
if (this.m.compareAndSet(false, true)) {
|
|
unsubscribe();
|
|
this.l.onError(e);
|
|
}
|
|
}
|
|
z2 = false;
|
|
action0 = this.o;
|
|
if (action0 != null) {
|
|
}
|
|
if (!z2) {
|
|
}
|
|
}
|
|
if (this.k.compareAndSet(j, j - 1)) {
|
|
break;
|
|
}
|
|
}
|
|
} else {
|
|
z3 = true;
|
|
}
|
|
if (z3) {
|
|
ConcurrentLinkedQueue<Object> concurrentLinkedQueue = this.j;
|
|
if (t == null) {
|
|
t = (T) e.b;
|
|
}
|
|
concurrentLinkedQueue.offer(t);
|
|
this.n.a();
|
|
}
|
|
}
|
|
|
|
@Override // rx.Subscriber
|
|
public void onStart() {
|
|
request(RecyclerView.FOREVER_NS);
|
|
}
|
|
}
|
|
|
|
/* compiled from: OperatorOnBackpressureBuffer */
|
|
public static final class b {
|
|
public static final a1<?> a = new a1<>();
|
|
}
|
|
|
|
public a1() {
|
|
int i = j0.a.a;
|
|
}
|
|
|
|
@Override // j0.k.b
|
|
public Object call(Object obj) {
|
|
Subscriber subscriber = (Subscriber) obj;
|
|
a aVar = new a(subscriber, null, null, this.j);
|
|
subscriber.add(aVar);
|
|
subscriber.setProducer(aVar.n);
|
|
return aVar;
|
|
}
|
|
}
|