public interface Completable
extends org.reactivestreams.Publisher<java.lang.Void>
| 限定符和类型 | 方法和说明 |
|---|---|
static Completable |
complete()
完成
|
static Completable |
create(java.util.function.Consumer<CompletableEmitter> emitterConsumer)
创建
|
default Completable |
delay(long delay,
java.util.concurrent.TimeUnit unit)
订阅延时
|
Completable |
doOnComplete(java.lang.Runnable doOnComplete)
当完成时
|
Completable |
doOnError(java.util.function.Consumer<java.lang.Throwable> doOnError)
当出错时
|
Completable |
doOnErrorResume(java.util.function.Function<java.lang.Throwable,Completable> doOnError)
当出错时,恢复为一个新流
|
static Completable |
error(java.lang.Throwable cause)
出错
|
void |
subscribe()
订阅
|
void |
subscribe(CompletableEmitter emitter)
订阅
|
default Completable |
subscribeOn(java.util.concurrent.Executor executor)
订阅于
|
default Completable |
then(Completable other)
当完成后(然后),下一个新流
|
Completable |
then(java.util.function.Supplier<Completable> otherSupplier)
当完成后(然后),下一个新流
|
Completable doOnError(java.util.function.Consumer<java.lang.Throwable> doOnError)
Completable doOnErrorResume(java.util.function.Function<java.lang.Throwable,Completable> doOnError)
Completable doOnComplete(java.lang.Runnable doOnComplete)
static Completable create(java.util.function.Consumer<CompletableEmitter> emitterConsumer)
Completable then(java.util.function.Supplier<Completable> otherSupplier)
default Completable then(Completable other)
default Completable subscribeOn(java.util.concurrent.Executor executor)
default Completable delay(long delay, java.util.concurrent.TimeUnit unit)
void subscribe()
void subscribe(CompletableEmitter emitter)
emitter - 发射器static Completable complete()
static Completable error(java.lang.Throwable cause)