reactor 相关问题

反应器设计模式是用于处理通过一个或多个输入同时传递给服务处理器的服务请求的事件处理模式。服务处理程序解复用传入的请求，并将它们同步分派给关联的请求处理程序。

这里是一段代码@Test public void test_mono_void_mono_empty（）{Mono.just（“ DATA”）.flatMap（s-> Mono.just（s.concat（“-”）.concat（s））.. 。

java project-reactor reactor

回答 1 投票 0

反应式编程是否比非反应式编程消耗更多的资源？

我们目前正面临Spring webFlux的性能问题。为了确定反应式编程的好处，我们实现了Spring Boot服务，该服务从...

java spring-boot project-reactor reactor spring-io

回答 2 投票 5

如何在春季创建反应堆热流？

我有以下代码。我以为使用发布可以创建一个热流，但是每个连接上的uniqueId是不同的。我希望create方法只执行一次，然后以...

java reactor

回答 1 投票 1

是否有办法找出ServerRequest是否具有主体？

我想检查ServerRequest是否包含正文。有没有办法找出事先调用bodyToMono方法的方法？

spring-webflux reactor

回答 1 投票 1

Reactor：Flux .subscribe（）与.toStream（）

我有一个函数：Flux queryPerson（），它查询数据库以生成对象并以Flux返回它们。当我使用.subscribe（）时，该应用程序仅通过代码运行并退出。它不等待...

java flux reactor spring-reactive

回答 1 投票 0

自动更新带有新记录的EventSource的客户端

我有以下代码。我想要的结果是，当创建新记录时，客户端将自动使用新信息进行更新。相反，以下代码仅从...

spring server-sent-events reactor

回答 1 投票 0

线程“主”中的异常，reactor.core.publisher.FluxFilter $ FilterSubscriber.onNext处的java.lang.NullPointerException

订阅方法似乎在filter方法之后给出了nullpointerexception。当我删除过滤器方法时，一切工作正常。为什么？通量通量=新的通量

java reactor

回答 1 投票 0

如何等待所有一次性元素何时完成？

让我们考虑以下代码：List > monoList = apiCall（）; List 一次性使用列表= monoList.stream（）.map（m-> m.subscribe（str-> {... ] >>

java spring spring-webflux reactor spring-reactive

回答 1 投票 0

当链中发生错误时更新原始单声道

假设我有这样的东西：Mono.just（a）.flatMap（...）//初始化//如果发生错误则设置字段.flatMap（...）// finalize .subscribe（）;在上一个flatMap中，我正在执行...

java project-reactor reactor

回答 1 投票 0

为什么从pywikibot调用scrapy蜘蛛会产生ReactorNotRestartable错误？

我能够使用CrawlerRunner或CrawlerProcess从另一个Python脚本调用一个抓爬虫。但是，当我尝试从pywikibot机器人调用同一蜘蛛调用类时，我得到了...

scrapy reactor pywikibot

回答 1 投票 0

如何从Mono平面图中获取通量？

我有以下代码：public Flux getFoos（String xyz）{return getBar（xyz）.flatMap（b-> Flux.empty（）））; }但是由于getBars（）返回一个...

spring reactor

回答 1 投票 0

通过扭曲的inlineCallbacks运行Scrapy蜘蛛

我有ImportError：没有名为'spiders'的模块，因此我认为在进行蜘蛛调用时没有环境变量。但是我不完全了解如何使它们正常工作。基本上，...

python scrapy twisted scrapy-spider reactor

回答 1 投票 1

Java Reactor：来自map（）的未处理异常，但是是从fromCallable（）处理的

在下面的两个示例中，第一个（带有map（）告诉我，readTree（）中存在未处理的异常，但在第二个示例中没有。为什么这样？谢谢！ Mono.just（jsonString）.map（...

java reactor

回答 1 投票 0

动态发布者集合都通过相同的流量发出

我正在尝试构建一种可以通过热通量（输出）发出的集线器服务，但是您也可以注册/注销通量Flux生产者/发布者（输入），我知道我可以做类似的事情：class ...

spring-webflux project-reactor reactor

回答 1 投票 1

如何通过完成磁通量创建单声道

我有一个从Flux源填充Map的类。我希望能够即时更新TheData（），但我希望getTheData（）能够返回解析为当前或待处理数据的Mono。 ...

java spring-webflux project-reactor reactor

回答 1 投票 1

Project Reactor将发布者一分为二，最少有两个订阅者

您如何在Reactor中将发布者一分为二，然后存在两个相同的数据流，以便在下游以不同的流进行处理？因此，我可以映射每个流并订阅...

java project-reactor reactor

回答 1 投票 0

Project Reactor将发布者一分为二

您如何在Reactor中将发布者一分为二，然后存在两个相同的数据流，以便在下游以不同的流进行处理？因此，我可以映射每个流并订阅...

java project-reactor reactor

回答 1 投票 0

带有Java Reactor的TarArchiveInputStream

[目前，我正在这样处理TarArchiveInputStream：私有Mono createEmployeeFromArchiveFile（）{return Mono.fromCallable（（）-> {return new Employee（）; ...

java reactor

回答 1 投票 0

基于日期时间属性的磁通发射元素

我有一种情况，我想根据事件中的日期时间属性来处理事件。到目前为止，我的尝试失败：class Data {private Integer id;私人LocalDateTime sendAt; }列表

java spring-webflux reactor

回答 1 投票 1

如何使用Reactor Flux处理CSV文件并以JSON输出

我有一个要使用Spring Reactor Flux处理的CSV文件。给定一个带有标头的CSV文件，该文件的前两列是固定的，并且可以包含多个可选数据列Id，Name，...

spring flux reactor

回答 1 投票 1

reactor 相关问题

最新问题