如何处理可<Response>观察



我有一个本地弹簧启动应用程序,它正在访问另一个PCF部署的应用程序。PCF申请给了我学生名单。

我正在使用以下方法击中相同的内容:

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

现在我无法从结果Observable中恢复List<Student>

尝试了很多方法,但没有真正起作用,即订阅结果等。

因此,在下面挣扎了几个小时之后,现在是解决方案。

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);

请建议,如果可以改进。

谢谢

最新更新