Android Retrofit2:如何将请求查询参数传递给响应？

Question

我依赖于retrofit2，该retrofit2配置为使用RxJava包装响应，并使用GSon解析它们。

我在用Reterfit做Rest服务。

@GET("search")
Observable<SearchResult> search(@Query("q") String query);

@GET("search")
Observable<SearchResult> search(@QueryMap Map<String, String> params);

@GET("search")
Observable<SearchResult> searchNext(@Query("q") String query, @Query("startKey") String startKey);

@GET("search")
Observable<SearchResult> searchNext(@QueryMap Map<String, String> params, @Query("startKey") String startKey);

search REST服务返回一个JSON

{
  "count": 2334,
  "nextBatchKey": "SADjdfsahoi023451sadfjlskdfj02134512",
  "results": [ .... ]
}

null

Retrofit retrofit = new Retrofit.Builder()
    .client(okHttpClient) // added interceptors
    .baseUrl(baseUrl) // my base url
    .addConverterFactory(GsonConverterFactory.create(gson)) // custom type html" target="_blank">adapter factory
    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
    .build();

它为我的接口生成服务，并使用GSON解析响应，并用RXJavaObservable包装它。

然后我获得服务：

MyService service = retrofit.create(MyService.class)

请注意，我不编写这个服务的代码，因为retrofit工作时，它使用我的接口(MyService)注释自动生成服务。

// obtain the service
MyService service = MyLibrarySDK.getService(context);
// perform the search operation
Observable<SearchResult> resultObservable =
    service.search(params); 

// then later result == the SearchResult
Observable<SearchResult> nextBatch =
    result.searchNext();

如果用户使用q=foo执行搜索调用，则不会在响应中接收到此信息。而我需要它。

由于referfit create the service，我不知道如何截获通过调用service.search()传递的方法参数。

解决这个问题的唯一方法是使用OKHTTP拦截器，将查询参数映射放置在ThreadLocal中，然后使用自定义的GSONTypeAdapter将这些参数注入到SearchResult对象中。

你有更好的/有创意的/优雅的主意吗？

Answer 1

不要认为在结果上有searchnext()，而应该在服务上有searchnext()。

尝试如下所示：

myservice.java

public class MyService {
    RestClient.GitApiInterface service = RestClient.getClient();
    String query;
    Observable<GitResult> resultObservable;

    public Observable<GitResult> getUsersByName(String query) {
        this.query = query;
        resultObservable = service.getUsersByName(query, 0).cache();
        return resultObservable;
    }

    public Observable<GitResult> searchNext() {
        Observable nextResultObservable = resultObservable
                .flatMap(new Func1<GitResult, Observable<?>>() {
                    @Override
                    public Observable<?> call(GitResult gitResult) {
                        return service.getUsersByName(query, gitResult.getNextPage());
                    }
                });

        return nextResultObservable;
    }
} 

final MyService service = new MyService();
// First load
service.getUsersByName("tom");
// consecutive calls
service.searchNext();