project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

通过键将GroupFlux收集到Hashmap中

我最近开始使用Project Reactor，我想出了一个我似乎无法弄清楚的情景。基本上我想分组某个流，然后获取哈希映射，如分组...

java project-reactor

回答 1 投票 0

如何从阻塞队列创建reactor Flux？

我正在尝试实现从BlockingQueue创建的反应器Flux，但不确定哪个运算符最适合我的用例？我正在创建一个流式REST端点，响应是需要的Flux ......

java spring-webflux project-reactor

回答 1 投票 0

Flux.onErrorContinue参数类型

有没有人知道Flux.onErrorContinue参数的原因如下：public final Flux onErrorContinue（BiConsumer errorConsumer）{...}代替......

java flux project-reactor

回答 1 投票 0

Spring boot + webflux：并行运行某些步骤时上下文丢失

Spring boot：2.1.3.RELEASE你好，我试图使用spring webflux的上下文功能来携带一个简单的变量。我有一个WebFilter设置这样的变量的上下文，我尝试...

java spring-boot spring-webflux project-reactor

回答 1 投票 4

在使用Spring Webflux时返回响应时在后台运行Mono

这个问题与春季网络流量中的返回有关，但我不认为它是相同的（至少答案对我来说不满意）。我有一个函数返回Mono时...

spring-boot spring-webflux project-reactor

回答 1 投票 0

Mono.count无限期阻止

我跑了这个：单声道 mono = Mono.empty（）; System.out.println（“mono.block：”+ mono.block（））;它产生：mono.block：如预期的那样。换句话说，调用块将返回...

java project-reactor

回答 1 投票 0

按并发任务数量（非基于时间）限制异步单声道

假设我有一个接受参数并返回Mono的方法异步完成。例如：Random random = new Random（）; ScheduledExecutorService ......

java project-reactor

回答 1 投票 1

使用groupBy进行Flux并行串行执行

说我有这个：Flux > intsGrouped = Flux.range（0,12）.groupBy（i - > i％3）;并说我有一个方法：单声道 getFromService（Integer i）; ...

java project-reactor

回答 1 投票 0

Files.createDirectory（）真的是非阻塞的吗？

我创造了这样的方法：Flux 下载（String bucket，List s3FileNames）{String tmpDirName = UUID.randomUUID（）。toString（）;路径目录= Paths.get（...

java nio project-reactor

回答 1 投票 0

将Flux的结果与Mono的结果相结合

我开始使用Project reactor和一个我很难挣扎的地方，我如何将来自Mono和Flux的东西结合起来。这是我的用例：public interface GroupRepository {Mono

spring-webflux project-reactor reactive-streams

回答 2 投票 2

使用Java中的反应包装器使用非阻塞IO逐行读取文件

有没有办法逐行读取本地文件而不阻塞任何线程（后台线程池计为阻塞）使用内置的CompletableFuture或反应流库如RxJava或...

java rx-java nonblocking project-reactor completable-future

回答 1 投票 -2

如何在多个Mono运算符中重用变量？

[可能重复，但到目前为止我还没有发现]请考虑以下代码：Mono.just（myVar）.flatMap（MyClass :: heavyOperation）.flatMap（MyClass :: anotherHeavyOperation）.flatMap（res - > ...

java reactive-programming project-reactor

回答 4 投票 1

Spring Webflux Reactor上下文

在下面的示例中，test2应该能够从test和test1访问上下文值，但似乎没有发生。欢迎任何见解。参考文献：http：// projectreactor ....

java spring-boot spring-webflux project-reactor

回答 2 投票 1

拆分和合并时Flux.fromStream失败

我有这个示例代码：Flux range = Flux.range（0,10）;助焊剂 longs = Flux.fromStream（new Random（）。longs（100,500）.boxed（））; //（1）// Flux longs = Flux ....

java project-reactor

回答 2 投票 1

我需要在没有存储库的情况下使服务无效[关闭]

我的任务是通过使用Flux / Mono使UserService成为被动的。我理解通量和单声道是如何工作的，但只使用存储库而不是arraylists。 UserServiceImpl：@ Slf4j @Service @ ...

java spring-boot reactive-programming project-reactor reactor

回答 1 投票 1

如何以reactor方式编写快捷循环

我有一个像下面这样的非反应堆时尚代码，迭代一个检查器列表并快捷返回“BAD”如果任何检查器返回false：public static String oldWay（）{List 跳棋......

project-reactor

回答 1 投票 0

使用WebClient发出多个请求

所以我的目标是使用WebClient发出多个并发请求，等待它们全部完成，然后合并结果。这是我到目前为止：...通量 ...

java spring spring-boot spring-webflux project-reactor

回答 1 投票 0

将流媒体流的WebClient帖子拆分为JSON阵列

我正在使用第三方REST控制器，它接受一个JSON对象数组并返回单个对象响应。当我使用有限的Flux从WebClient POST时，代码可以工作（我假设，...

java spring-webflux project-reactor reactive-streams

回答 1 投票 1

查找特定记录并进行更新

查找特定记录并更新studentRepository.findByStudid（studId）.log（）。map（existingStud - > {return studentRepository.save（existingStud）; // ...

mongodb spring-boot reactive-programming project-reactor

回答 1 投票 0

发送另一个消息后如何接收单声道消息

如何发送buf然后接收一个msg方法Mono send（ByteBuf buf）{//如何发送buf然后收到一个msg}我试图通过从...发送一个msg来实现这个方法

java project-reactor reactor-netty

回答 3 投票 0

project-reactor 相关问题

最新问题