rxjava中just()运算符的不同用法

问题描述 投票:0回答:1

据说,在网上阅读的所有文件中,“只需要操作员列表并只发出一次”。但是,链接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() {

                    }
                });
android rx-java
1个回答
1
投票

你可以看到<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


推荐问答