Описание тега java-flow

Вопросы с тегом
2 ответа

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

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

Проблема Jasperreport с подотчетом с использованием javaflow

У меня есть проблема с подотчетом, использующим javaflow с Jasperreport 6.7.0 в соответствии с "Полным руководством по JasperReports" - Теодор Данчу, Лучиан Чирита, стр. 130. Мне нужно, чтобы избежать вызова различных потоков, когда отчет вызывается…
16 фев '19 в 13:25
3 ответа

Хорошая реализация / поддержка java.util.concurrent.Flow.Processor<T, R>

Недавно я нашел хорошую поддержку для Publisher с помощью projectreactor.io: Flux.create(fluxSink -&gt; { for (int i = 0; i &lt; 10; i++) fluxSink.next(i); fluxSink.complete(); }) .map(...) .subscribe(...); Есть ли хорошая поддержка для Proccessor? …
17 ноя '17 в 12:11
3 ответа

Запустить поток в главном потоке

Я снова сравниваю RxJava с Java 9 Flow. Я вижу, что Flow по умолчанию работает асинхронно, и мне было интересно, есть ли способ заставить его работать синхронно. Иногда мы просто хотим использовать его не для Nio, а для сахарного синтаксиса и иметь …
30 сен '17 в 18:53
2 ответа

Java 9 Flow определяет подписчика с лямбдами

Я начинаю играть с Java 9 Flow API, и первое, что я нашел и не люблю, похоже, что мы не можем использовать лямбда-выражения, когда мы передаем реализацию подписчика в издателя, как мы можем сделать с RxJava Поэтому я должен определить и реализовать …
30 сен '17 в 12:52
0 ответов

Java Flow.Subscriber - Как мне получить издателя onComplete?

Я создаю пользовательскую систему событий, используя JDK 9 Flow API, поэтому у меня есть комната (которая расширяет UserSubscriver класс выше), он может иметь много пользователей, и каждый пользователь может предлагать (рассылать) обновления в любое…
01 мар '18 в 13:53
0 ответов

Реактивный поток Java - может ли подписчик вернуть значение?

Я пытаюсь реализовать реактивный поток Java (паттер дизайн наблюдателя). Я использовал доступные образцы. у меня нет проблем с отправкой значений подписчикам, но я не могу заставить подписчика отправить издателю значение обратно. Есть ли способ, кот…
17 июн '18 в 22:12
0 ответов

Java Flow.Subscriber - Как я могу отписаться?

Я создаю пользовательскую систему событий, используя JDK 9 Flow API, поэтому у меня есть комната (которая реализует Flow.Subscriber&lt;Notification&gt;), у него может быть много пользователей, и каждый пользователь может предлагать (рассылать) обнов…
01 мар '18 в 19:29
2 ответа

Как прочитать тело HttpRequest в Java 11?

В тесте я хотел бы заглянуть внутрь тела HttpRequest. Я хотел бы получить тело в виде строки. Кажется, что единственный способ сделать это - подписаться на BodyPublisher, но как это работает?
23 апр '19 в 17:07
1 ответ

Издатель синхронного представления

Можно ли заставить подписчика работать в том же потоке, что и издатель (синхронно)? Я могу использовать CompletableFuture, но он дает только один результат. Но что, если мне нужно много результатов, доставленных подписчику. Пожалуйста, посмотрите на…
27 фев '21 в 18:27