二、RxJava 创建：create，just，fromArray，empty，range

本文主要是介绍二、RxJava 创建：create，just，fromArray，empty，range，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

1.项目地址

在MainActivity3那里

2.讲解

1.普通创建 create：这里发射一个“A”，然后打印出来：

//普通创建：Observable.create(new ObservableOnSubscribe<String>() {@Overridepublic void subscribe(@NonNull ObservableEmitter<String> emitter) throws Throwable {emitter.onNext("A");emitter.onComplete();}}).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onNext(@NonNull String s) {Log.d(TAG, "onNext: "+s);}@Overridepublic void onError(@NonNull Throwable e) {}@Overridepublic void onComplete() {}});

2.用just创建，这里打印了A，B

这里的

emitter.onNext("A");
emitter.onComplete();

在里面默认执行了

Observable.just("A","B").subscribe(new Observer<String>() {@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onNext(@NonNull String s) {Log.d(TAG, "onNext: "+s);}@Overridepublic void onError(@NonNull Throwable e) {}@Overridepublic void onComplete() {}});

3.用fromArray，来打印string[]里面的值：

String[] strings={"1","2","3"};Observable.fromArray(strings).subscribe(new Observer<String>() {@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onNext(@NonNull String s) {Log.d(TAG, "onNext: "+s);}@Overridepublic void onError(@NonNull Throwable e) {}@Overridepublic void onComplete() {}});Log.d(TAG, "onCreate: rxJava:"+l1);

4.用empty来创建（发送不操作）

Observable.empty().subscribe(new Observer<Object>() {@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onNext(@NonNull Object o) {}@Overridepublic void onError(@NonNull Throwable e) {}@Overridepublic void onComplete() {Log.d(TAG, "onComplete: ");}});

5.用range来创建，可以设置第几个开始打印，打印个数

这里从15开始打印，打印五个（15,16,17,18,19）

Observable.range(15,5)//开始打印的值，打印个数.subscribe(new Observer<Integer>() {@Overridepublic void onSubscribe(@NonNull Disposable d) {}@Overridepublic void onNext(@NonNull Integer integer) {Log.d(TAG, "onNext: "+integer);}@Overridepublic void onError(@NonNull Throwable e) {}@Overridepublic void onComplete() {}});