Create操作符的作用
构建一个新的可观察对象,在合适的时机调用Observer的onNext,onCompelete和onError方法。一个完备的Observable必须调用onCompelete或onError一次,并且之后不能再调用Observer的其他方法。
示例代码
RxJava版本:2.2.19
Observable.create(new ObservableOnSubscribe<String>() {
@Override
public void subscribe(ObservableEmitter<String> emitter) {
for (int i = 0; i < 100; i++) {
emitter.onNext("Step " + i);
}
emitter.onComplete();
}
}).subscribe(new Observer<String>() {
@Override
public void onSubscribe(Disposable d) {}
@Override
public void onNext(String s) {}
@Override
public void onError(Throwable e) {}
@Override
public void onComplete() {}
});