📅  最后修改于: 2020-11-12 05:27:08             🧑  作者: Mango
Single类表示单个值响应。单一可观察项只能发出一个成功值或一个错误。它不会发出onComplete事件。
以下是io.reactivex.Single
public abstract class Single
extends Object
implements SingleSource
以下是Single Observable运行的顺序协议-
onSubscribe (onSuccess | onError)?
使用您选择的任何编辑器(例如,C:\> RxJava)创建以下Java程序。
import java.util.concurrent.TimeUnit;
import io.reactivex.Single;
import io.reactivex.disposables.Disposable;
import io.reactivex.observers.DisposableSingleObserver;
import io.reactivex.schedulers.Schedulers;
public class ObservableTester {
public static void main(String[] args) throws InterruptedException {
//Create the observable
Single testSingle = Single.just("Hello World");
//Create an observer
Disposable disposable = testSingle
.delay(2, TimeUnit.SECONDS, Schedulers.io())
.subscribeWith(
new DisposableSingleObserver() {
@Override
public void onError(Throwable e) {
e.printStackTrace();
}
@Override
public void onSuccess(String value) {
System.out.println(value);
}
});
Thread.sleep(3000);
//start observing
disposable.dispose();
}
}
使用javac编译器编译类,如下所示:
C:\RxJava>javac ObservableTester.java
现在如下运行ObservableTester-
C:\RxJava>java ObservableTester
它应该产生以下输出-
Hello World