平坦可映射截断

Question

我需要将一个项目列表映射到可观察的项目中，然后使用另一个函数处理每个可观察的项目flatmap，以将某个REST API调用的结果持久化到数据库中。

API调用将正确返回所有项。但是，FlatMapiteTable不会将所有项目传递给最后一个flatMap。

这是代码。

restApi.getContacts(user)
        .flatMapIterable(new Func1<List<Contact>, List<Contact>>() {
            @Override
            public List<Contact> call(List<Contact> contacts) {
                return contacts;
            }
        }

        .flatMap(new Func1<Contact, Observable<Integer>>() {
            @Override
            public Observable<Integer> call(Contact Contact) {
                return create(Contact);
            }
        })

我不想使用doOnEach或doOnNext，我的问题是关于FlatMapiteTable的行为。

知道为什么我不能到达最后一张平面图中的所有项目吗？

谢谢。

Answer 1

首先，为了便于检查，请尝试以下内容

而不是：

    .flatMapIterable(new Func1<List<Contact>, List<Contact>>() {
        @Override
        public List<Contact> call(List<Contact> contacts) {
            return contacts;
        }
    }

试试这个：

    .flatMap(new Func1<List<Contact>, Observable<Contact>>() {
        @Override
        public Observable<Contact> call(List<Contact> contacts) {
            return Observable.from(contacts);
        }
    })

如果没有帮助，请添加以下代码：

    restApi.getContacts(user)
        .doOnNext(new Action1<List<Contact>>() {
            @Override
            public void call(List<Contact> contacts) {
                Log.i(LOG_TAG, "first doOnNext size: " + contacts.size());
            }
        })
        .flatMapIterable(new Func1<List<Contact>, List<Contact>>() {
            @Override
            public List<Contact> call(List<Contact> contacts) {
                Log.i(LOG_TAG, "flatMapIterable size: " + contacts.size());
                return contacts;
            }
        })
        .flatMap(new Func1<Contact, Observable<Integer>>() {
            @Override
            public Observable<Integer> call(Contact Contact) {
                return create(Contact);
            }
        })
        .toList()
        .doOnNext(new Action1<List<Integer>>() {
            @Override
            public void call(List<Integer> integers) {
                Log.i(LOG_TAG, "second doOnNext size: " + contacts.size());
            }
        })

并在这里打印Logcat输出。