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