如何在 RXJava/Android 中连接两个订阅

Question

如何绑定两个订阅，例如：

1) Retrofit&RX 将 JSON 转换为 recyclerView 中显示的字符串列表。

    restClient.getCatFacts()
            .subscribeOn(Schedulers.newThread())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(new Subscriber<CatFactsResponse>() {
                @Override
                public void onCompleted() {
                    Log.i(TAG, "onCompleted");
                }

                @Override
                public void onError(Throwable e) {
                    Log.i(TAG, "onError, " + e.getMessage());
                }

                @Override
                public void onNext(CatFactsResponse catFactsResponse) {
                    catFactsList = catFactsResponse.getCatFacts();
                }
            });

2) 和 Jack Wharton 的 RxBinding 库来响应 EditText 小部件中所做的更改。

subscription = RxTextView
            .textChangeEvents(editText)
            .debounce(400, TimeUnit.MILLISECONDS)
            .observeOn(Schedulers.newThread())
            .subscribe(new Observer<TextViewTextChangeEvent>() {
                @Override
                public void onCompleted() {
                    Log.i(TAG, "onCompleted");
                }

                @Override
                public void onError(Throwable e) {
                    Log.i(TAG, "onError >> " + e.getMessage());
                }

                @Override
                public void onNext(TextViewTextChangeEvent textViewTextChangeEvent) {
                    Log.i(TAG, textViewTextChangeEvent.text().toString());
                }
            });

获取使用 EditText 动态过滤的列表。我应该使用类之类的主题吗？如果是，那么它应该是什么样子？感谢您的帮助:)

Answer 1

你应该使用 flatMap 运算符

    subscription = RxTextView
            .textChangeEvents(editText)
            .debounce(400, TimeUnit.MILLISECONDS)
            .map(new Func1<TextViewTextChangeEvent, String>() {
                @Override
                public String call(TextViewTextChangeEvent textViewTextChangeEvent) {
                    return textViewTextChangeEvent.text();
                }
            })
            .flatMap(new Func1<String, Observable<CatFactsResponse>>() {
                @Override
                public Observable<CatFactsResponse> call(String text) {
                    return restClient.getCatFacts(text)
                            .subscribeOn(Schedulers.io())
                            .observeOn(AndroidSchedulers.mainThread());
                }
            })
            .subscribe(...);

如何在 RXJava/Android 中连接两个订阅

How to connect two subscriptions in RXJava/Android

java

android

android-edittext

rx-java

rx-android