java - 如何从 Observable> 创建 Observable

Question

如果我有 Letter 的 List 的 Observable

public Observable<List<Letter>> getAToZList() {
        return Observable.create(
                new Observable.OnSubscribe<List<Letter>>() {
                    @Override
                    public void call(Subscriber<? super List<Letter>> subscriber) {
                        List<Letter> aToZLetters = getLetters();
                        subscriber.onNext(aToZLetters);
                        subscriber.onCompleted();
                    }
                }
        );
    }

然后我如何创建一个 Observable 来观察单个 Letter 并为 List 中的每个字母发出一个？

public Observable<Letter> getAToZ() {
        return Observable.create(
                     getAToZList().something() ??
        );
    }

https://github.com/ReactiveX/RxJava

Answer 1

使用flatMapIterable。例如:

observable.flatMapIterable(l -> l).subscribe()