Как обработать Observable <Response> - PullRequest
       13

Как обработать Observable <Response>

1 голос
/ 19 сентября 2019

У меня есть одно локальное приложение весенней загрузки, которое запускает другое развернутое приложение PCF.Приложение PCF дает мне список студентов.

Я нажимаю так же, используя:

Observable<Response> result = RxObservable.newClient()
  .target(url)
  .request()
  .rx()
  .get();

Теперь я не могу вернуть List<Student> из результата Observable.

Перепробовал много подходов, но на самом деле ничего не работает, т.е. подписка на результат и т. Д.

1 Ответ

0 голосов
/ 22 сентября 2019

Так что после нескольких часов борьбы, решение пока что.

Observable observable =  result.map(response -> response.readEntity(List.class));
DeferredResult<ResponseEntity<Response>> deferredResult = new DeferredResult(Duration.ofMillis(10000L).toMillis());
    observable.subscribe((response) -> {
        ResponseEntity<Response> responseData = new ResonseEntity(response, HttpStatus.OK);
        deferredResult.setResult(responseData);
    },  deferredResult::setErrorResult);

Пожалуйста, предложите, если это можно улучшить.

Спасибо

...