Результаты поиска по запросу "reactive-programming"
Что такое пользователь, monoUser и getId? Ни один из них не в оригинальном вопросе. Поэтому все, что вы пытаетесь - это решить гипотетический запрос.
я есть метод, который принимает Mono в качестве параметра. Все, что я хочу, это получить реальную строку из нее. Гуглил, но не нашел ответа, кроме вызова block () над объектом Mono, но он сделает блокирующий вызовпоэтому хочу ...
http://reactivex.io/documentation/operators/zip.html
емаУ меня есть два Apis. Api 1 дает мне список предметов, а Api 2 дает мне более подробную информацию для каждого из предметов, которые я получил от Api 1. То, как я его решил, приводит к плохой производительности. ВопросЭффективное и быстрое ...
обсудить возможность добавить один.
я есть MovieRepository, который расширил ReactiveMongoRepository. Я хочу сохранить один POJO реактивным способом. Но ReactiveMongoRepository не предоставляет метод сохранения для Mono или Publisher. Я должен использоватьblock() метод или ...
Здесь говорится, что в будущих версиях это будет устаревшим
сне 5: WebClient - это интерфейс, представляющий основную точку входа для выполнения веб-запросов. Он был создан как часть модуля Spring Web Reactive и будет заменять классический RestTemplate в этих сценариях. Новый клиент - реактивное, ...
Это различие переносит немного семантической информации в тип, указывая грубую мощность асинхронной обработки. Например, HTTP-запрос дает только один ответ, поэтому нет смысла выполнять операцию подсчета. Таким образом, выражение результата такого HTTP-вызова как Mono имеет больше смысла, чем выражение его как Flux, поскольку он предлагает только операторы, которые имеют отношение к контексту с нулевыми элементами или одним элементом.
сно документации: Поток - это поток, который может излучать 0..N элементов: Flux<String> fl = Flux.just("a", "b", "c");Mono - это поток из 0..1 элементов: Mono<String> mn = Mono.just("hello");И так как оба являются реализациями интерфейса ...
может быть полезным (по крайней мере, первые 15 минут)
ользую RxJava для обработки некоторых уведомлений, которые мы извлекаем из очереди. Казалось, что RxJava отлично работает с простым рабочим процессом, теперь, когда появляются новые требования, этот процесс усложняется с появлением ...
пытаться
я есть способы сделать то же самое, хотя я предпочитаю первый. Но первый подход, похоже, не работает. (tap() не срабатывает) // does not work this.actions$.pipe( ofType(LayoutActions.Types.CHANGE_THEME), takeUntil(this.destroyed$), tap(() => { ...
gitter.im/reactor/reactor
инающий вSpring Web-Flux, Я написал контроллер следующим образом: @RestController public class FirstController { @GetMapping("/first") public Mono<String> getAllTweets() { return Mono.just("I am First Mono") } }Я знаю, что одно из ...
Два UUID от каждого объекта данных.
я есть постраничный ответ от URL, я хочу продолжать нажимать URL следующей страницы, который я получаю из предыдущего ответа, и продолжать собирать элементы, пока у меня не будет URL «nextPage» в моем ответе. Как добиться этого реактивным ...
тогда это более элегантно сделано без FRP.
ример программы на Haskell FRP с использованием библиотеки реактивного банана. Я только начинаю чувствовать себя с Хаскеллом, и особенно не совсем понял, что значит FRP. Я действительно ценю некоторую критику кода ниже {-# LANGUAGE ...