96 lines
2.4 KiB
Java
96 lines
2.4 KiB
Java
package j0.l.a;
|
|
|
|
import j0.o.l;
|
|
import java.util.concurrent.atomic.AtomicLong;
|
|
import rx.Producer;
|
|
import rx.Subscriber;
|
|
/* compiled from: OperatorTake.java */
|
|
/* loaded from: classes3.dex */
|
|
public class b2 extends Subscriber<T> {
|
|
public int j;
|
|
public boolean k;
|
|
public final /* synthetic */ Subscriber l;
|
|
public final /* synthetic */ c2 m;
|
|
|
|
/* compiled from: OperatorTake.java */
|
|
/* loaded from: classes3.dex */
|
|
public class a implements Producer {
|
|
public final AtomicLong j = new AtomicLong(0);
|
|
public final /* synthetic */ Producer k;
|
|
|
|
public a(Producer producer) {
|
|
this.k = producer;
|
|
}
|
|
|
|
@Override // rx.Producer
|
|
public void j(long j) {
|
|
long j2;
|
|
long min;
|
|
if (j > 0 && !b2.this.k) {
|
|
do {
|
|
j2 = this.j.get();
|
|
min = Math.min(j, b2.this.m.j - j2);
|
|
if (min == 0) {
|
|
return;
|
|
}
|
|
} while (!this.j.compareAndSet(j2, j2 + min));
|
|
this.k.j(min);
|
|
}
|
|
}
|
|
}
|
|
|
|
public b2(c2 c2Var, Subscriber subscriber) {
|
|
this.m = c2Var;
|
|
this.l = subscriber;
|
|
}
|
|
|
|
@Override // j0.g
|
|
public void onCompleted() {
|
|
if (!this.k) {
|
|
this.k = true;
|
|
this.l.onCompleted();
|
|
}
|
|
}
|
|
|
|
@Override // j0.g
|
|
public void onError(Throwable th) {
|
|
if (!this.k) {
|
|
this.k = true;
|
|
try {
|
|
this.l.onError(th);
|
|
} finally {
|
|
unsubscribe();
|
|
}
|
|
} else {
|
|
l.b(th);
|
|
}
|
|
}
|
|
|
|
@Override // j0.g
|
|
public void onNext(T t) {
|
|
if (!isUnsubscribed()) {
|
|
int i = this.j;
|
|
int i2 = i + 1;
|
|
this.j = i2;
|
|
int i3 = this.m.j;
|
|
if (i < i3) {
|
|
boolean z2 = i2 == i3;
|
|
this.l.onNext(t);
|
|
if (z2 && !this.k) {
|
|
this.k = true;
|
|
try {
|
|
this.l.onCompleted();
|
|
} finally {
|
|
unsubscribe();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
@Override // rx.Subscriber
|
|
public void setProducer(Producer producer) {
|
|
this.l.setProducer(new a(producer));
|
|
}
|
|
}
|