Как выполнить пользовательскую реализацию Retrofit2.Call <T>

Ответ 1

Сначала создайте класс ServiceManager -

public final class ServiceManager {

    private static ServiceManager sServiceManager;

    /**
     * Gets the instance of the web services implementation.
     *
     * @return the singleton instance.
     */
    public static ServiceManager get() {
        if (sServiceManager == null) {
            sServiceManager = new ServiceManager();
        }
        return sServiceManager;
    }

    /**
     * Creates the services for a given HTTP Url, useful when testing
     * through multiple endpoints and unit testing
     *
     * @param clazz the service class.
     * @param <T>   type of the service.
     * @return the created services implementation.
     */
    public <T> T createService(Class<T> clazz) {
        return createService(clazz, HttpUrl.parse(ServiceApiEndpoints.SERVICE_ENDPOINT));
    }

    /**
     * Creates the services for a given HTTP Url, useful when testing
     * through multiple endpoints and unit testing
     *
     * @param clazz   the service class.
     * @param httpUrl the endpoint
     * @param <T>     type of the service.
     * @return the created services implementation.
     */
    public <T> T createService(Class<T> clazz, HttpUrl httpUrl) {
        Retrofit retrofit = getRetrofit(httpUrl);
        return retrofit.create(clazz);
    }

    public <T> T createService(Class<T> clazz, Retrofit retrofit) {
        return retrofit.create(clazz);
    }

    private Retrofit getRetrofit(HttpUrl httpUrl) {
        return new Retrofit.Builder()
                .baseUrl(httpUrl)
                .client(createClient())
                .addConverterFactory(getConverter())
                .build();
    }

    public Retrofit getPlainRetrofit(HttpUrl httpUrl) {
        return new Retrofit.Builder()
                .baseUrl(httpUrl)
                .client(new OkHttpClient.Builder().build())
                .addConverterFactory(getConverter())
                .build();
    }

    private Converter.Factory getConverter() {
        return GsonConverterFactory.create();
    }


    private OkHttpClient createClient() {
        return new OkHttpClient.Builder().addInterceptor(new RequestInterceptor()).build();
    }

}

ServiceApiEndpoints - это класс, содержащий конечные точки службы.

final class ServiceApiEndpoints {

    public static final String SERVICE_ENDPOINT = "your_app_url";
}

Создать интерфейс APIService

public interface APIService {
 String GET_INFO = "get_info";

    @GET(GET_INFO)
    Call<ResInfo[]> getInfo();
}

Создать модель ResInfo.

public class ResInfo {
    private static final String FIELD_CONTENT = "content";

    public String getContent() {
        return mContent;
    }

    public void setContent(final String content) {
        mContent = content;
    }


    @SerializedName(FIELD_CONTENT)
    private String mContent;

    public ResInfo(){

    }
}

Вызовите запрос.

    private Call<ResInfo[]> mGetInfoAPICall;

    APIService apiService=ServiceManager.get().createService(APIService.class);
    mGetInfoAPICall = apiService.getInfo();
    mGetInfoAPICall.enqueue(new Callback<ResInfo[]>() {
    @Override
    public void onResponse(Call<ResInfo[]> call, Response<ResInfo[]> response) {

    }

    @Override
    public void onFailure(Call<ResInfo[]> call, Throwable t) {

    }
});

Ответ 2

Я рассказываю ниже пример, чтобы помочь вам в реализации модифицированного образа.

Создайте свой ресурс, подобный этому (MyResource.java).

Call<TKBaseResponse> testConnection(@@Url String customUrl);

Инициализировать дооснащение

private Resource getRetrofitResource(){
   //Initialize retrofit.
   final Retrofit = .....//your code to initialize retrofit
   return retrofit.create(MyResource.class);
}

Чтобы реализовать очередь вызовов (асинхронные переадресации вызовов), вам необходимо передать свой ресурс и обработчик ответа, который является вашей пользовательской реализацией в методе enqueue. Я отправляю свою реализацию ResponseHandler рядом.

public abstract class ResponseHandler<T> {

    private static final String TAG = ResponseHandler.class.getSimpleName();

    private static final String LINE_SEPARATOR = System.getProperty("line.separator");

    private final Context context;

    public ResponseHandler() {
        this(null);
    }

    public ResponseHandler(final Context context) {
        this.context = context;
    }


    public abstract void onResponse(final T response);

    public void onError(final ErrorResponse errorResponse) {
        if (context == null) {
            return;
        }
        Log.e(TAG, "An error occurred while invoking service. Error Code: " + errorResponse.getErrorCode() + LINE_SEPARATOR + "Message: " + errorResponse.getMessage() + LINE_SEPARATOR);
        final AlertDialog.Builder alertBuilder = new AlertDialog.Builder(context);
        alertBuilder.setCancelable(true);
        alertBuilder.setTitle(R.string.title_server_error_dialog);
        alertBuilder.setMessage(R.string.network_error_message);
        alertBuilder.setPositiveButton(R.string.text_ok, new DialogInterface.OnClickListener() {
            @Override
            public void onClick(final DialogInterface dialog, final int which) {
                dialog.dismiss();
            }
        });
        alertBuilder.show();
    }

    public void onFailure(Throwable throwable) {
        if (context == null) {
            return;
        }
        Log.e(TAG, "An error occurred while invoking service", throwable);
        final AlertDialog.Builder alertBuilder = new AlertDialog.Builder(context);
        alertBuilder.setCancelable(true);
        alertBuilder.setTitle(R.string.title_network_error_dialog);
        alertBuilder.setMessage(R.string.network_error_message);
        alertBuilder.setPositiveButton(R.string.text_ok, new DialogInterface.OnClickListener() {
            @Override
            public void onClick(final DialogInterface dialog, final int which) {
                dialog.dismiss();
            }
        });
        alertBuilder.show();
    }

}

Создайте ответ дескриптора метода.

protected <T> void handleResponse(Call<T> call, final ResponseHandler<T> responseHandler) {
        call.enqueue(new Callback<T>() {
            @Override
            public void onResponse(final Call<T> call, final Response<T> response) {
               if (response.isSuccess()) {
                if (responseHandler != null ) {
                    responseHandler.onResponse(response.body());
                }
            } else {
                final ErrorResponse errorResponse = parseError(response);
                if (responseHandler != null) {
                    responseHandler.onError(errorResponse);
                }
            }
            }

            @Override
            public void onFailure(final Call<T> call, final Throwable throwable) {
               if (responseHandler != null) {
                responseHandler.onFailure(throwable);
            }
            }
        });
    }

Пожалуйста, дайте мне знать, если у вас есть какие-либо сомнения по этому поводу.

Теперь от вызова вашего ресурса, как показано ниже.

final MyResource resource = getRetrofitResource();
final Call<TKBaseResponse> response = resource .testConnection("ANY_URL_OF_YOUR_CHOICE");
handleResponse(response, new ResponseHandler<TKBaseResponse>(){

 public void onResponse(final TKBaseResponse response){
      //Do whatever you want to do here..
 }
    });