使用RxJava/RxAndroid迭代列表

Question

我对RxJava/RxAndroid还不熟悉，但我一直坚持使用我的用例。

我尝试迭代一个列表

我成功地转换了整个列表，然后收到了我的列表

我尝试了from的运算符，但如果我使用from（List

这是我的代码如何转换整个列表

private List<A> listOfA;

private startConversion() {
    Observer observer = new Observer<List<B>>() {
        @Override
        public void onCompleted() {

        }

        @Override
        public void onError(Throwable e) {
            e.printStackTrace();
        }

        @Override
        public void onNext(List<B> convertedItems) {
            onConversionCompleted(convertedItems);
        }
    };

    Observable<B> observervable = Observable.fromCallable(new Callable<List<B>>() {
        @Override
        public List<B> call() throws Exception {
            return convertListOfAToListOfB(listOfA);
        }
    });

    subscription = observable
                .subscribeOn(Schedulers.newThread())
                .observeOn(AndroidSchedulers.mainThread())
                .subscribe(observer);
}

PS：这是伪代码。

谢谢你的帮助！




Answer 1

您还可以使用Observable。fromIterable（list）从列表中创建可观察对象列表。然后可以迭代这些项并将其转换为列表。

 Observable.fromIterable(list)
            .filter(item -> item.getId().equals("SampleId")
            .toList();

Answer 2

给你。。举个简单的例子：

public static void main(String[] args) {
    String[] s = {"a", "b", "c"};
    Observable.from(s).map(value -> "A"+value).subscribe(result -> System.out.println(result));
    Observable.timer(2, TimeUnit.SECONDS).toBlocking().subscribe();
}

正如您提到的list，为了简单起见，我使用了一个数组，甚至list也可以用作from（）的参数

Answer 3

如果您想在单独的线程中逐个转换每个项目，可以这样做。

    Observable.from(list)    
            .map(input -> {
                // transform each A -> B
            })
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(item -> {

            });

如果您已经有可观察的发射列表，并希望将其转换为序列，请使用以下选项：

        listObservable
            .flatMap(Observable::from)
            .subscribe(item -> {

            });

如果要将这两种方法结合起来，并在一个位置转换所有值，但要逐个发射它们，可以执行以下操作：

    Observable.create(subscriber -> {
        for (Item item : items) {
            subscriber.onNext(transformA2B(item));
        }

        subscriber.onCompleted();
    });