改装！返回一个通用的可观察类型答案

【问题标题】：retrofit ! returning a generic observable type改装！返回一个通用的可观察类型
【发布时间】：2016-05-03 08:26:15
【问题描述】：

我正在编写代码以从我的 android 客户端访问我的 Web 服务。目前我正在使用改造来为各种调用返回一个可观察的类型。目前我有 4 个（如下所示）

@FormUrlEncoded
@POST("/app/{pathto}")
Observable<List<EntryItem>> getNewsAndComments(@Path("pathto") String pathto, @FieldMap Map<String, String> fieldnames);


/**
 * adding a comment. returns observable
 * with message entity type
 *
 * @param pathto
 * @param fieldnames
 * @return
 */

@FormUrlEncoded
@POST("/app/{pathto}")
Observable<message> postComment(@Path("pathto") String pathto, @FieldMap Map<String, String> fieldnames);


@FormUrlEncoded
@POST("/{pathto}")
Call<message> regDevice(@Path("pathto") String pathto ,@FieldMap Map<String, String> fieldnames);

/**
 * return a Map of canteen menu items!
 *
 * @param path
 * @param fielditems
 * @return
 */

@FormUrlEncoded
@POST("/app/{pathto}")
Observable<Map<String, ArrayList<CantItem>>> getCanteenItems(@Path("path") String path, @FieldMap Map<String,String> fielditems);

我还使用通用 RestService 工厂来创建通用改造服务。我从我正在阅读的一篇博客文章中偷了这个:) .

 public static <T> T getRetroFitService(final Class<T> clazz, final String endpoint)
{

    final Retrofit retrofit = new Retrofit.Builder()
            .addConverterFactory(GsonConverterFactory.create())
            .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
            .baseUrl(endpoint)
            .build();

    T service = retrofit.create(clazz);
    return service;
}

在我返回可观察对象等的接口中，许多方法调用看起来都一样，所以我尝试将其更改为以下通用调用

Observable<List<T>>

不幸的是，改造似乎不喜欢这样。我想知道有没有办法解决这个问题，所以我可以使接口调用更加通用，例如将我自己的 TypeAdapter 传递给 RestServiceFactory？另外，我对改造和 rx-android 还比较陌生，所以任何建议都值得赞赏。谢谢！

【问题讨论】：

标签： android generics retrofit rx-android

【解决方案1】：

您可以使用 flatMap 功能。我在我的应用程序中做了同样的事情。

OrderController.getOrderInterface()
                    .resendEventSMS(Common.getUserToken(this),order_id)
                    .subscribeOn(Schedulers.io())
                    .flatMap(result ->Observable.just(new RxSelection(RESEND_SMS,result)))
                    .onErrorReturn(throwable ->new RxSelection(RESEND_SMS_ERROR,getError(throwable)))
                    .observeOn(AndroidSchedulers.mainThread());
            .subscribe(mOrderObserver);

Rx 选择类是一个泛型类：

public class RxSelection {

    private int what;
    private Object obj;

    public RxSelection(int what, Object obj){
        this.obj=obj;
        this.what=what;
    }
    public int getWhat(){
        return what;
    }
    public Object getObj(){
        return obj;
    }
}

观察者是这样的：

mOrderObserver = new Observer<RxSelection>() {
            @Override
            public void onSubscribe(Disposable d) {
                Common.log(EventOrderDetailActivity.this,TAG, "subscribe");
            mDisposableList.add(d);
        }

        @Override
        public void onNext(RxSelection value) {
            Common.log(EventOrderDetailActivity.this,TAG, "OnNext");
            switch (value.getWhat()) {
                case GET_EVENT_ORDER_DETAILS:
                    mEventOrderDetail= (EventOrderDetail) value.getObj();
                    setupData();
                    break;

                case RESEND_SMS:
                    HashMap<String,String> sms= (HashMap<String,String>) value.getObj();
                    Toast.makeText(EventOrderDetailActivity.this, sms.get("success"), Toast.LENGTH_SHORT).show();
                    break;
}

在这里，您将所有调用的结果转换为 RxSelection 对象。您只需要 1 个观察者来观察具有任何类型结果的任何服务的结果

【讨论】：