-
如何在不使用reduce()或last()折叠的情况下获取Flux的最后一项
如何在不使用reduce()或last()折叠的情况下获取Flux的最后一项?这是我的用例: 1)我有一个 -
RxJava:并行处理并合并结果(不弄乱顺序)
我对使用反应流非常陌生,遇到了以下问题,这使我很难解决。目的是从MongoDB数据库中获取许多文档。 -
如何使用RxJava2从无限Stream <Integer>创建Observable <Integer>?
我正在尝试将RxJava从1升级到2。在我的旧代码中,我有如下方法: <pre class="lang-java prettyprint-override">< -
如何在循环中合并Mono的值?
我有一个实体列表<code>input = window.prompt() if(input.includes("stop working")){ console.log("not working") -
如何将Monix反应流转换为资源丰富的值并确保适当的发布?
我正在使用Monix反应流。 我有一组文件名<code>f: Observable[File]</code>,我想将其转换为打开的资源<cod -
在流中使用Source.queues和Sink.queues的Akka Streams应用程序中无法处理项目
我正在尝试使用akka.stream.scaladsl.Source和Sink队列类创建(Akka HTTP)流处理流。 我正在使用队列,因为我的 -
将CDI事件桥接到Microprofile Reactive Message Broker
我跟随<a href="https://quarkus.io/guides/kafka" rel="nofollow noreferrer">Quarkus - Using Apache Kafka with Reactive Messaging</a>创 -
AMQP消费者停止在第127条消息上接收
<strong> <em>问题</em> </strong>:发布者应用不断向Artemis经纪人发布AMQP消息-但是,消费者应用在第127位之后 -
Java反应器:不适当的阻塞方法调用
我将其添加到代码中的两个位置 <pre class="lang-java prettyprint-override"><code>Flux.empty() .collectList() .bl -
信号R的Flutter反应式编程(流)
我尝试在flp中实现一个聊天系统,在asp.net核心中有一个后端,并通过SignalR进行实时连接。 目标是 -
连接丢失后,RSocket恢复会话/流
我正在使用RSocket通道并尝试实现恢复功能,以防与服务器的连接丢失。在服务器和移动设备上尝试了resu -
Java反应器-链Mono <Void>与另一个产生Mono <Object>的异步任务 实施不正确那么,如何解决呢?但是,如何正确解决呢?
我有以下异步任务: <pre class="lang-java prettyprint-override"><code>select count(*) filter(where cm.email is null) i -
阻止Spring WebFlux WebClient对新订阅执行新的交换
<code>DefaultWebClient</code>的{{1}}实现为: <pre class="lang-java prettyprint-override"><code>exchange</code></pre> <p -
Vertx WebClient响应正文中的反应流发布者
我正在尝试为Vertx <a href="https://vertx.io/docs/vertx-web-client/java/" rel="nofollow noreferrer">web-client</a>写一个包装器 -
流量生成器-当没有可用数据时如何处理?
<strong>问题:没有更多数据时,我们该如何处理<a href="https://projectreactor.io/docs/core/release/api/reactor/core/publ -
如何在反应式Mongo驱动程序中模拟FindPublisher
我正在使用Java中的mongo反应式驱动程序和reactstreams库编写应用程序。 我有以下DAO代码: <pre cla -
限制Reactor中的订阅并发
我有一个实用程序类来集中处理Reactor的<code>Publisher</code>来处理Cassandra查询: <pre><code>public Mono<Resu -
Spring反应式流-意外关闭
我们正在将Spring Cloud Reactive Streams与RabbitMQ结合使用。 Spring Reactive Stream似乎在将消息从队列中拉 -
Smallrye Mutiny中的switchIfEmpty替代品是什么
在RxJava 2和Reactor中,如果当前流中没有元素,则有一种<code>switchIfEmpty</code>类似的方法可以切换到新流。 -
Webflux:重复用尽后,不会触发OnErrorResume
我尝试使用<code>onErrorResume</code>重复耗尽后执行代码,但是未触发onErrorResume。 这是代码示例 <p -
如何处理嵌套磁通和Monos
我的数据存储在Cosmos中,并且是分层的,并存储在不同的表中。 <pre><code>Hiearchy of Data OnBoardingDefinitio -
从akka.stream.scaladsl.Source读取第一个字节
我正在尝试从<code>akka.stream.scaladsl.Source[ByteString, Any]</code>读取前16个字节并返回<code>[Array[Byte], Source[ByteSt -
quarkus:IllegalStateException:您试图在IO线程上执行阻止操作。不允许这样做,因为这会阻塞IO线程
我对夸克有一件事难以理解。 我将JPA与Oracle一起使用。所以我有错误 IllegalStateException:您试图在IO线程 -
mongodb反应流中的订阅者实例
我遇到过mongodb反应流驱动程序,它们对于异步操作似乎非常有用。此外,对于我们执行的每个操作,我 -
vert.x反应写入流到AWS SDK 2
我想用vert.x编写代码,该文件从文件中读取行(用\ n分隔),然后将它们解析为dynamodb-我正在使用Java aws -
Reactor Flux flatMap操作员吞吐量/并发控制并实现背压
我正在使用Flux构建我的反应性管道。在管道中,我需要调用3个不同的外部系统REST API,它们的访问率非 -
Project Reactor:用Mono的结果丰富通量的结果
我正在努力将反应式编程引入我的公司。我正在构建一个活动推荐系统的简单演示,以证明其性能优势 -
我收到错误消息“程序类型已存在:androidx.lifecycle.ReportFragment $ ActivityInitializationListener”
<pre><code>df <- structure(list(Firm = c("A", "A", "A", "A", "A", "B", "B", " -
Reactor-动态更改flatMap并发
是否可以在运行时更改Reactor Flux flatMap并发性? <a href="https://projectreactor.io/docs/core/release/api/reactor/ -
RxJava一位发布者的多个使用者
我正在编写某种带有缓存的中间件HTTP代理。工作流程是: <ol> <li>客户请求此代理获取资源</li> <li>如