mirror of
https://github.com/VibedByKaKi/alexandroid.git
synced 2026-11-15 02:17:18 +01:00
23 lines
478 B
Java
23 lines
478 B
Java
package io.reactivex.rxjava3.internal.util;
|
|
|
|
import org.reactivestreams.Subscriber;
|
|
|
|
/* compiled from: r8-map-id-b9432e0f623b4a4bff4ba50a8a24c4aafad2c1e11092747b9fb5e6a22af5a940 */
|
|
/* loaded from: classes10.dex */
|
|
public interface QueueDrain<T, U> {
|
|
boolean accept(Subscriber<? super U> subscriber, T t);
|
|
|
|
boolean cancelled();
|
|
|
|
boolean done();
|
|
|
|
boolean enter();
|
|
|
|
Throwable error();
|
|
|
|
int leave(int i);
|
|
|
|
long produced(long j);
|
|
|
|
long requested();
|
|
}
|