据说,在网上阅读的所有文件中,“只需要操作员列表并只发出一次”。但是,链接https://www.androidhive.info/RxJava/rxjava-operators-just-range-from-repeat/中有这样的用法:这里需要10个参数并发出10次。为什么没有人提到它?我找不到任何关于它的官方文档。你能澄清一下吗?
Observable.just(1, 2, 3, 4, 5, 6, 7, 8, 9, 10)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Observer<Integer>() {
@Override
public void onSubscribe(Disposable d) {
}
@Override
public void onNext(Integer integer) {
Log.d(TAG, "onNext: " + integer);
}
@Override
public void onError(Throwable e) {
}
@Override
public void onComplete() {
}
});
你可以看到<T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6)
实现,看看它是使用from
运算符:
public static <T> Observable<T> just(T t1, T t2, T t3, T t4, T t5, T t6) {
return from((T[])new Object[] { t1, t2, t3, t4, t5, t6 });
}
另外,为了更好地解释,请参阅@dglozano在评论中提到的answer。
更新:link到RxJava2中的Observable类,link到RxJava中的同一个类1.我写的代码片段来自RxJava1