Как конвертировать Observable <String>в JSON

Question

Я хочу преобразовать объект Observable в объект json

ObjectMapper mapper = new ObjectMapper();
    Observable<String> response = accountSearchService.searchAccount(paramMap, "", 0, 1);
    mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);
    AccountSearchResult resultDto = mapper.convertValue(response.subscribe().toString(), AccountSearchResult.class);

Это то, что я пытаюсь сделать, но получаю OnErrorNotImplementedException.Пожалуйста, кто-нибудь, помогите мне в этом.

Answer 1

Метод subscribe() не возвращает действительное значение подписки, он просто запускает подписку на это наблюдаемое.Вместо этого вы должны «прослушать» подписку и выполнить операцию, как только она будет завершена.Как то так:

ObjectMapper mapper = new ObjectMapper();
    Observable<String> response = accountSearchService.searchAccount(paramMap, "", 0, 1);
    mapper.disable(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES);

    response.subscribe(stringValue -> {
            AccountSearchResult resultDto = mapper.convertValue(stringValue, AccountSearchResult.class);
        }, throwable -> {
            //onError
        });