reactive-programming 相关问题

反应式编程是一种围绕数据流和变化传播的编程范例。

spring boot应用连接docker中副本集的问题

我在 mac os (Apple M3 Pro) 上部署了 docker。我正在从本地主机运行 Spring Boot 应用程序。但是，无法连接到副本集。 2024-11-19T21:46:50.470+03:00 ...

spring-boot reactive-programming mongodb-replica-set

回答 1 投票 0

反应流（monix）运算符组合，用于缓冲具有重叠元素的时间跨度

我有一个连续发射的 Observable[T] ，我想要一个 Observable[List[T]] ，它为源发射的每个元素在指定持续时间内发射最后一个元素。例子可观察到的。范围...

scala observable rx-java reactive-programming monix

回答 1 投票 0

当选定的行用作反应值时，闪亮的 DT 外观会变得混乱

当使用其输入来自的反应值时，通过 DT 包的 DataTables 界面显示的表格显得杂乱（例如无序的元素、奇怪的分页......）。

r shiny reactive-programming dt

回答 1 投票 0

DT：根据 R闪亮应用程序中另一列的选择输入动态更改列值

我正在尝试创建一个表（使用DT，请不要使用rhandsontable），该表几乎没有现有列，一个selectinput列（其中每一行都有可供选择的选项），最后是另一列...

r shiny datatables reactive-programming dt

回答 1 投票 0

Spring WebFlux - 配置客户端不解压数据

我正在编写一个 Spring 项目，我想使用反应式编程。我首先创建一个客户端 bean： @豆公共 WebClient webClient() { 返回Web客户端 .builder() ...

spring spring-webflux reactive-programming

回答 1 投票 0

在 Quarkus 服务层中使用 Mutiny 处理多个异常

我正在使用 Mutiny 进行反应式编程开发 Quarkus 应用程序，并且在服务层中遇到异常处理问题。我有一个保留用户的方法，我...

reactive-programming quarkus quarkus-panache

回答 1 投票 0

响应式 API 需要调用并行的下游 API 并等待响应

我有许多设备（目前有八个，但将来可能会更多），它们带有简单的阻塞 HTTP REST API。进行 GET 调用来给出一个值，API 会响应成功或失败，但是...

java spring-boot rest reactive-programming

回答 1 投票 0

RX 中没有主题的反馈循环

我有以下运动方程移动 = 目标位置 - 位置位置=位置+移动其中 target_position 是一个流，position 初始化为零。我想要一个...

reactive-programming rxjs

回答 2 投票 0

Kafka Streams 和 CompletableFuture（或异步 java api）

我正在研究 Apache Kafka Stream SPI。我想知道是否有一种方法可以在 mapValues 方法内部执行异步代码。例如从外部存储检索数据。有没有办法整合...

java apache-kafka reactive-programming apache-kafka-streams completable-future

回答 1 投票 0

在更改单个模块中的输入时，如何更改多个 Shiny 模块的输入？

我正在使用一个相当大的 Shiny 应用程序，其中包含多个模块。应用程序中的每个选项卡都是其自己的模块。某些选项卡具有一些共享输入，以及各自选项卡的不同输入。这...

r shiny reactive-programming shinymodules

回答 2 投票 0

如何测试Spring WebClient何时重试？

我需要实现以下行为：发出 REST 发布请求如果响应返回状态为 429 Too much requests，则最多重试 3 次，延迟 1 秒如果第三次重试失败或出现任何情况

rx-java reactive-programming project-reactor spring-webclient

回答 3 投票 0

收集流不会产生任何更新

在示例项目中，我有一个包含两个用例的 viewModel。两个用例都调用同一个存储库。通过流程获取将存储库存储在 StateFlow 中的任务列表。其他规定...

android mobile android-jetpack-compose reactive-programming kotlin-stateflow

回答 1 投票 0

使用 spring webflux 的非阻塞 REST API

我需要使仪表板非阻塞 REST API 具有以下详细信息：客户资料——来自第 3 方 API 客户帐户——来自另一个第 3 方 API 顾客受益

java spring spring-boot spring-webflux reactive-programming

回答 1 投票 0

在 IAM 无密码身份验证令牌过期之前更新

我的 Spring 服务是以反应式方式编写的，因此我们使用 r2dbc 来建立数据库连接。现在我想使用 AWS RDS 启用 IAM 无密码身份验证。 @豆公开

spring-boot amazon-rds reactive-programming r2dbc aws-iam-authenticator

回答 1 投票 0

Spring Webflux：嵌套 Flatmap 替代品

我有一个场景，第二个单声道依赖于第一个单声道，而 ThridMono 调用依赖于第二个单声道输出。我编写的代码如下。首先Mono.flatMap{ val secondaryMono = callWebservice(

java kotlin reactive-programming spring-webflux project-reactor

回答 2 投票 0

Spring Boot 响应式编程中 subscribeOn(Schedulers.boundedElastic()) 的意外线程行为

我在 Spring Boot 中使用 getAPI 进行反应式编程。在应用 subscribeOn(Schedulers.boundedElastic()) 时，我希望线程是有界弹性的。然而，我却没有这么做，而是……

java spring-boot reactive-programming project-reactor

回答 1 投票 0

如何避免 Spring Integration Flow 中的响应式服务阻塞？

我正在学习Java集成，当我从反应式服务获取数据并在IntegrationFlow中使用它时遇到问题，我的代码在这里，是我的想法的简单演示： @Autowired 私人

spring reactive-programming integration

回答 1 投票 0

Webflux WebCient 的时间成本

我有一个 Spring Boot 服务，它使用 WebClient 调用另一个外部服务。外部服务的平均延迟约为 15 ms（通过 Datadog 测量）。但是当外部API是c...

java spring-boot spring-webflux reactive-programming project-reactor

回答 1 投票 0

Proactor VS Reactor

Proactor 和 Reactor 之间的真正区别是什么？前摄器分派一个函数，然后轮询返回的 future 以获得就绪结果。 Reactor 将函数分派到事件中...

c++ design-patterns concurrency reactive-programming reactor-pattern

回答 2 投票 0

使用反应式夸库斯和休眠/华丽来坚持多个实体

作为反应式 quarkus/hibernate/panache 的新手，我非常感谢您对如何将循环中的实体持久保存到数据库的反馈。让我们假设在某个时候我们有一个部门列表...

reactive-programming persistence quarkus-panache

回答 1 投票 0

reactive-programming 相关问题

最新问题