rx-java

0зной

1ответ

RxJava 2 Дооснащение и динамические URL-адреса и аннотация @url

Я пытаюсь построить интерфейс для нескольких дисков. т.е. http://server.com/firstQuery http://server.com/secondQuery Это моя Модифицированной интерфейс ого public interface RequestInterfaceRx<T> {

2зной

1ответ

Что заменило AsyncEmitter в rxjava 2?

Я пытаюсь перенести реактивный проект из rxjava 1 в версию 2. Я использовал AsyncEmitter для присоединения к существующему фиду, указав BackpressureMode. Однако я не нашел сопоставимого способа сделат

0зной

1ответ

списка Изменить на наблюдаемом

У меня есть List<JSONObject>, что я создаю наблюдаемый из принести ссылку на изображение с помощью стороннего API: Observable.from(list) .map(jsonObject -> (String) jsonObject.get("url")) .f

1зной

1ответ

RxJava Spring Boot microservice AsyncReturnValueHandler дает 404 Нет сообщений ОШИБКА

Я написал микро-сервис Spring Boot с помощью RxJava, и вы можете найти здесь project. Все отлично работает отлично. Теперь в настоящее время я преобразовываю RxJava Observable s в DeferredResult внутр

3зной

1ответ

Вывести значение после того, как onNext вызывается после определенного времени

Я хочу испустить случайное значение через 10 секунд после вызова onNext. Таким образом, onNext будет вызван на 12345 и через 10 секунд позжеNext должен быть вызван для случайного числа. Каков наилучши