mirror of
https://github.com/VibedByKaKi/alexandroid.git
synced 2026-11-12 17:07:17 +01:00
29 lines
777 B
Java
29 lines
777 B
Java
package rx;
|
|
|
|
import rx.annotations.Experimental;
|
|
|
|
/* compiled from: r8-map-id-b9432e0f623b4a4bff4ba50a8a24c4aafad2c1e11092747b9fb5e6a22af5a940 */
|
|
@Experimental
|
|
/* loaded from: classes12.dex */
|
|
public interface AsyncEmitter<T> extends Observer<T> {
|
|
|
|
/* compiled from: r8-map-id-b9432e0f623b4a4bff4ba50a8a24c4aafad2c1e11092747b9fb5e6a22af5a940 */
|
|
public enum BackpressureMode {
|
|
NONE,
|
|
ERROR,
|
|
BUFFER,
|
|
DROP,
|
|
LATEST
|
|
}
|
|
|
|
/* compiled from: r8-map-id-b9432e0f623b4a4bff4ba50a8a24c4aafad2c1e11092747b9fb5e6a22af5a940 */
|
|
public interface Cancellable {
|
|
void cancel() throws Exception;
|
|
}
|
|
|
|
long requested();
|
|
|
|
void setCancellation(Cancellable cancellable);
|
|
|
|
void setSubscription(Subscription subscription);
|
|
}
|