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