Create操作符的作用


构建一个新的可观察对象,在合适的时机调用Observer的onNext,onCompelete和onError方法。一个完备的Observable必须调用onCompelete或onError一次,并且之后不能再调用Observer的其他方法。
image.png

示例代码

RxJava版本:2.2.19

  1. Observable.create(new ObservableOnSubscribe<String>() {
  2. @Override
  3. public void subscribe(ObservableEmitter<String> emitter) {
  4. for (int i = 0; i < 100; i++) {
  5. emitter.onNext("Step " + i);
  6. }
  7. emitter.onComplete();
  8. }
  9. }).subscribe(new Observer<String>() {
  10. @Override
  11. public void onSubscribe(Disposable d) {}
  12. @Override
  13. public void onNext(String s) {}
  14. @Override
  15. public void onError(Throwable e) {}
  16. @Override
  17. public void onComplete() {}
  18. });

参考资料

http://reactivex.io/documentation/operators/create.html