问使用RxJava和可重用重新配置创建rest客户端-可观察

EN

compile('com.google.code.gson:gson:2.8.2')
    compile('com.squareup.okhttp3:logging-interceptor:3.14.1')
    compile('com.squareup.okhttp3:okhttp:3.14.1')
    compile('com.squareup.retrofit2:converter-gson:2.5.0')
    compile('com.squareup.retrofit2:retrofit:2.5.0')
    compile('com.squareup.retrofit2:adapter-rxjava2:2.5.0')

public class RetrofitService {

    private static OkHttpClient getClient() {
        HttpLoggingInterceptor loggingInterceptor = new HttpLoggingInterceptor();
        loggingInterceptor.setLevel(HttpLoggingInterceptor.Level.BODY);
        OkHttpClient.Builder builder = new OkHttpClient.Builder()
                .readTimeout(60, TimeUnit.SECONDS)
                .connectTimeout(60, TimeUnit.SECONDS)
                .addInterceptor(loggingInterceptor)
                .addInterceptor(chain -> {
                    Request request = chain.request();
                    return chain.proceed(request
                            .newBuilder()
                            .header("Content-Type", "application/json")
                            .method(request.method(), request.body()).build());
                });
        return builder.build();
    }

    private static Gson getGson() {
        return new GsonBuilder()
                .create();
    }

    private static Retrofit getRestAdapter(String baseUrl) {
        return new Retrofit.Builder()
                .baseUrl(baseUrl)
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create())
                .addConverterFactory(GsonConverterFactory.create(getGson()))
                .client(getClient())
                .build();
    }

    static RepositoryInterface getService(String baseUrl) {
        return getRestAdapter(baseUrl).create(RepositoryInterface.class);
    }
}

public interface RepositoryInterface {
    
    @POST("user")
    Observable<Response<Void>> createUser(
            @Header("S-Key") String sKey,
            @Header("X-Id") String xId,
            @Body HashMap<String, String> body
    );

    @GET("user/{X-Id}")
    Observable<Response<ApiUser>> getUser(
            @Header("S-Key") String sKey,
            @Path("X-Id") String xId
    );
}