Описание тега reactive-streams

Описание тега Вопросы с тегом
NoneA standard for asynchronous stream processing with non-blocking back pressure on the JVM
2 ответа

Как преобразовать Reactor Flux<String> в InputStream

Учитывая, что у меня есть Flux&lt;String&gt; неизвестного размера, как я могу преобразовать его в InputStream что другая библиотека ожидает? Например, с помощью WebClient я могу добиться этого, используя этот подход WebClient.get('example.com').exch…
05 авг '18 в 14:17
0 ответов

Пустой ответ при подписке на GraphQL

Следуя этому примеру, Я реализовал свой собственный издатель Publisher&lt;VendorCostInfo&gt; vendorCostInfo(VendorCostInfoFilter filter) { return vendorCostInfoPublisher.getPublisher(vendorCostInfoFilter); } и подписка с приведенной ниже эмиттерной …
04 авг '18 в 02:52
1 ответ

Reactor 3.x: есть ли оператор для throttleLatest (conflate)?

В rx-java 2.x есть оператор с именем throttleLatest, который объединяет входящие события на основе заданного времени: https://github.com/ReactiveX/RxJava/pull/5979 Есть ли подобный оператор в Reactor 3? Или возможно получить то же поведение, комбини…
01 окт '18 в 17:56
1 ответ

Используйте процессор Reactive-Streams с RxJava 2.0

У меня есть org.reactivestreams.Processor что я хотел бы использовать с RxJava 2.0. Тем не менее, хотя есть преобразования для интеграцииorg.reactivestreams.Publisher с RxJava, как io.reactivex.Flowable#fromPublisherмне не понятно как лучше интегрир…
13 ноя '16 в 08:27
1 ответ

Почему Абонент запрашивает разное количество элементов в разных случаях?

Я изучаю реактивные потоки и утилиту публикации-подписки, и я использую поведение по умолчанию Publisher(Flux в моем случае) и Subscriber. У меня есть два сценария, оба имеют одинаковое количество элементов в Flux. Но когда я анализирую логи, метод …
29 дек '17 в 07:46
1 ответ

Зачем нужен моно тип в Reactor 3?

Reactor 3 имеет 2 основных типа данных, оба из которых являются реактивными издателями потоков. reactor.core.publisher.Mono&lt;T&gt; reactor.core.publisher.Flux&lt;T&gt; Я понимаю разницу между Mono как потоком из 0 или 1 элементов и Flux как потоко…
09 янв '18 в 15:58
1 ответ

Завершить запрос с последним товаром в потоке

Я хотел бы завершить GET запрос с последним доступным товаром в потоке. Этот поток, в частности, объединяет события, созданные актером и уже индивидуально используемые WebSocket. Допустим, событие можно представить следующим образом: final case clas…
16 июн '18 в 12:56
2 ответа

Скала Акка стрим: как пройти через сек

Я пытаюсь обернуть несколько блокирующих звонков в Future. Возвращаемый тип Seq[User] где User это case class, Следующее просто не скомпилируется с жалобами на наличие различных перегруженных версий. Какие-либо предложения? Я попробовал почти все ва…
10 сен '15 в 07:17
2 ответа

Java 9 Поведение потока Предлагаемый метод SubmissionPublisher

Я играл с Java Flow offer оператор, но после того, как прочитал документацию и сделал мой тест, я не понимаю. Вот мой тест @Test public void offer() throws InterruptedException { //Create Publisher for expected items Strings SubmissionPublisher&lt;S…
30 сен '17 в 11:15
2 ответа

В весенней загрузке микросервис на основе webflux, кто подписчик?

Примечание. Здесь термины "подписчик" и "подписка" используются в спецификации реактивных потоков. Рассмотрим следующие методы @RestController в микросервисе на основе весенней загрузки на основе webflux. @GetMapping(path = "/users", produces = Medi…
10 янв '18 в 06:51
1 ответ

Отмена исключения происходит при подписке на подключаемый горячий источник

Я использую реактор с активной зоной 3.1.4. Рассмотрим следующий фрагмент кода: Flux&lt;String&gt; flux = Flux.&lt;String&gt;create(sink -&gt; sink.next("test")) .replay(1) .refCount(); flux.subscribe(System.out::println); flux.next().subscribe(Syst…
20 фев '18 в 15:36
1 ответ

Преобразовать бесконечный поток конечных потоков в бесконечный поток - Reactive X

Каким образом в Reactive x (в идеале с примерами в RxJava или RxJs) этого можно добиться? a |-a-------------------a-----------a-----------a---- s1 |-x-x-x-x-x-x -| (subscribe) s2 |-x-x-x-x-x-| (subscribe) s2 |-x-x-x-x-x-| (subscribe) ... sn S |-x-x-…
02 сен '17 в 17:18
1 ответ

Как включить ssl в реактивном клиенте mongodb при весенней загрузке?

Я в настоящее время сталкиваюсь с проблемой при создании реактивного монгоклиента, когда я предоставляю URL с опцией ssl=true. Я создаю конфигурационный класс при весенней загрузке, где я создаю Reactive mongoclient, используя следующую опцию: Mongo…
27 июн '18 в 02:24
1 ответ

Решение CompletableFuture для решения Reactor (или Akka)

У меня есть следующий метод, используя CompletableFuture как это: public AClass aMethod() { CompletableFuture&lt;SomeClassA&gt; someClassAFuture = CompletableFuture.supplyAsync(() -&gt; someMethodThatReturnsA()); CompletableFuture&lt;SomeClassB&gt; …
30 апр '18 в 02:36
2 ответа

Как реактивные потоки используются в Slick для вставки данных

В документации Slick приведены примеры использования Reactive Streams только для чтения данных как средства DatabasePublisher. Но что произойдет, если вы захотите использовать свою базу данных как Sink и обратно в зависимости от скорости вставки? Я …
04 апр '16 в 10:27
2 ответа

Реактивные потоки - пакетирование с таймаутом

Я пытаюсь заменить библиотеку обработки собственных журналов, которая очень похожа на ReactiveStreams io.projectreactor, Цель состоит в том, чтобы уменьшить объем поддерживаемого нами кода и использовать все новые функции, добавленные сообществом (с…
12 июл '17 в 10:48
0 ответов

Интеграционное тестирование Spring SseEmitters

Я искал подсказки о том, как лучше всего протестировать методы Spring MVC Controller, которые возвращают SseEmitters. Я подошел довольно коротко, но у меня есть метод проб и ошибок, который проверяет асинхронное многопоточное поведение. Ниже приведе…
10 май '16 в 14:00
1 ответ

Как я могу опубликовать или подписаться на материализованный график потока Akka Stream?

Я играю с Akka Stream и пытаюсь понять его гибкость после материализации. Один из способов сделать это - использовать API реактивных потоков низкого уровня: http://doc.akka.io/api/akka-stream-and-http-experimental/1.0-M3/ Однако вам необходимо опред…
17 фев '15 в 13:33
4 ответа

Опубликовать против подписки в Project Reactor 3

Я использую publishOn против подписки на одном и том же потоке следующим образом: System.out.println("*********Calling Concurrency************"); List&lt;Integer&gt; elements = new ArrayList&lt;&gt;(); Flux.just(1, 2, 3, 4) .map(i -&gt; i * 2) .log(…
03 янв '18 в 07:54
0 ответов

Драйвер реактивных потоков MongoDB для Java

Я знаю, что этот драйвер выполняет "Reactive Streams API", но какой тип Threadpool лежит в основе этой реализации? Например, Redisson использует Netty, но что используется в этом API MongoDB Reactive Streams?
06 ноя '18 в 17:35