Retrotif2 + RxJava отправка запроса POST не удалась - PullRequest
Новая
       17

Retrotif2 + RxJava отправка запроса POST не удалась

0 голосов
/ 24 августа 2018

Я хочу отправить запрос POST с помощью Retrofit + RxJava, но он не работает, и я не знаю причину. В одном упражнении это работает, в другом - не хочу работать: 

private void sendMerchantInfo() {
        try {
            String advertiserOriginalDeepLink = "https://mywebsite.com/main-1?param1=value1&param2=value2";
                String urlGetParams = LinkParser.getUrlGETParams(advertiserOriginalDeepLink);

                Map<Object, Object> merchantInfo = LinkParser.parseUrlGetParams(urlGetParams);
                String merchantInfoJson = new Gson().toJson(merchantInfo); //{"param1":"value1","param2":"value2"}

                String url = "https://api.endpoint.com/v1/system/merchant/process";
                userService = this.serviceGenerator.createService(UserService.class, true);
                final Observable observable = userService.sendUserInfo(
                        url, new RetrofitMapBody(merchantInfo))
                        .doOnNext(new Consumer<ResponseBody>() {
                            @Override
                            public void accept(ResponseBody responseBody) throws Exception {
                                //handle 200 OK.
                            }
                        })
                        .onErrorResumeNext((ObservableSource<? extends ResponseBody>) v ->
                                Crashlytics.log("Send user info attempt failed."))
                        .subscribeOn(Schedulers.from(threadExecutor))
                        .observeOn(postExecutionThread.getScheduler());
                addDisposable(observable.subscribe());
            }
        } catch (Exception exception) {
            Crashlytics.log("Send user info attempt failed. " + exception.getMessage());
        }
    }

Я подозреваю, что проблема в этой части, я пытаюсь отправить запрос в OnCreate() метод: 

.subscribeOn(Schedulers.from(threadExecutor))
.observeOn(postExecutionThread.getScheduler());

Пытался использовать это, но без эффекта: 

.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());

Что я делаю не так? Это всегда вызывает onErrorResumeNext() Это, вероятно, что-то с потоками, потому что однажды я получил исключение: networkonmainthreadexception. Пожалуйста, помогите.

1 Ответ

0 голосов
/ 25 августа 2018

Попробуйте использовать RxJava2 Адаптер , это сэкономит вам много!

Шаг 1: Модифицированная настройка клиента 

   private Retrofit getRetrofitClient() {
        return new Retrofit.Builder()
                .baseUrl(BASE_URL)
                .addConverterFactory(GsonConverterFactory.create())
                .addCallAdapterFactory(RxJava2CallAdapterFactory.create()) //option 1
                .addCallAdapterFactory(RxJava2CallAdapterFactory.createWithScheduler(Schedulers.newThread())) //option 2
                .build();
    }

Шаг 2: Интерфейс APIService (пример) 

@GET("endpoint")
Single<ResponseModel> fetch();

Шаг 3: Использование 

  Single<ResponseModel> fetch() {
        return getRetrofitClient()
                    .create(APIService.class)
                    .fetch();
    }

  • Любой не-2xxHTTP-ответ будет заключен в HttpException, из которого можно извлечь код состояния, сообщение о состоянии и полный HTTP-ответ.

  • Любые ошибки подключения будут включены в IOException

И это все, что вам нужно сделать, чтобы обернуть ваш сетевой вызов в любой поток RxJava.

...