92 lines
2.4 KiB
Java
92 lines
2.4 KiB
Java
package rx;
|
|
|
|
import c.d.b.a.a;
|
|
import j0.g;
|
|
import rx.internal.util.SubscriptionList;
|
|
public abstract class Subscriber<T> implements g<T>, Subscription {
|
|
private static final long NOT_SET = Long.MIN_VALUE;
|
|
private Producer producer;
|
|
private long requested;
|
|
private final Subscriber<?> subscriber;
|
|
private final SubscriptionList subscriptions;
|
|
|
|
public Subscriber() {
|
|
this(null, false);
|
|
}
|
|
|
|
public Subscriber(Subscriber<?> subscriber) {
|
|
this(subscriber, true);
|
|
}
|
|
|
|
public Subscriber(Subscriber<?> subscriber, boolean z2) {
|
|
this.requested = Long.MIN_VALUE;
|
|
this.subscriber = subscriber;
|
|
this.subscriptions = (!z2 || subscriber == null) ? new SubscriptionList() : subscriber.subscriptions;
|
|
}
|
|
|
|
private void addToRequested(long j) {
|
|
long j2 = this.requested;
|
|
if (j2 == Long.MIN_VALUE) {
|
|
this.requested = j;
|
|
return;
|
|
}
|
|
long j3 = j2 + j;
|
|
if (j3 < 0) {
|
|
this.requested = Long.MAX_VALUE;
|
|
} else {
|
|
this.requested = j3;
|
|
}
|
|
}
|
|
|
|
public final void add(Subscription subscription) {
|
|
this.subscriptions.a(subscription);
|
|
}
|
|
|
|
@Override // rx.Subscription
|
|
public final boolean isUnsubscribed() {
|
|
return this.subscriptions.j;
|
|
}
|
|
|
|
public void onStart() {
|
|
}
|
|
|
|
public final void request(long j) {
|
|
if (j >= 0) {
|
|
synchronized (this) {
|
|
Producer producer = this.producer;
|
|
if (producer != null) {
|
|
producer.j(j);
|
|
} else {
|
|
addToRequested(j);
|
|
}
|
|
}
|
|
} else {
|
|
throw new IllegalArgumentException(a.p("number requested cannot be negative: ", j));
|
|
}
|
|
}
|
|
|
|
public void setProducer(Producer producer) {
|
|
long j;
|
|
Subscriber<?> subscriber;
|
|
boolean z2;
|
|
synchronized (this) {
|
|
j = this.requested;
|
|
this.producer = producer;
|
|
subscriber = this.subscriber;
|
|
z2 = subscriber != null && j == Long.MIN_VALUE;
|
|
}
|
|
if (z2) {
|
|
subscriber.setProducer(producer);
|
|
} else if (j == Long.MIN_VALUE) {
|
|
producer.j(Long.MAX_VALUE);
|
|
} else {
|
|
producer.j(j);
|
|
}
|
|
}
|
|
|
|
@Override // rx.Subscription
|
|
public final void unsubscribe() {
|
|
this.subscriptions.unsubscribe();
|
|
}
|
|
}
|