1回答
我期望代码等待Mono完成，然后收集结果，但这从未发生过。 为什么？下面是我的代码： public static void main(String[] args) throws Exception { Mono<Integer> mono2 = Mono.fromCallab
浏览 52提问于2020-01-27得票数 2
1回答
Monix任务中为空
、、、
项目反应器有一些类似Mono.emptyT的东西，它可以在特殊情况下处理，当你没有任何东西时，它被评估。在Monix Task中有类似的东西吗？def getItemFromList[T](inp: Mono[List[T]]): Mono[T] = { moList.flatMap[T]((list: List[T]) => {
if (list.isEmpty) Mono</
浏览 19提问于2019-03-15得票数 0
我已经创建了一个String Monos List<Mono<String>> myList的列表。现在我需要将它们连接在一个大字符串中。StringBuilder builder = new StringBuilder();
mono ->}
return builder.toString() //<- is "&quo
浏览 47提问于2019-06-20得票数 1
回答已采纳
1回答
问题是Uni<>(Hibernate Reactive )取代了Mono<> ( Project )，从现在起，它的行为不再像项目反应器提供的那样明显。Uni<>和反应器的Mono<>/Flux<>之间是否有兼容的工具？
已经对GitHub repos进行了研究，尝试通过自定义spring启动器连接反应性类型。
浏览 8提问于2022-11-22得票数 0
1回答
我已经通读了项目反应器中的reactor.core.publisher.Mono类的Javadoc，但是我仍然不明白使用Mono.never()方法的意义。使用Mono.never()的用例有哪些？
浏览 3提问于2018-01-16得票数 5
为了简化我的转换操作，我正在尝试将CompletableFuture包装在一个反应器Mono类型中。一般来说，项目反应器更方便！stuff"); 问题是，当我的主代码调用CompletableFuture (s3AsyncClient.getObject)时，执行线程突然切换到CompleteableFuture线程，并且调用Mono的主方法在CompletableFuture完成之前返回。基本上，在上面的示例中，在s3AsyncClient.getObject完成</
浏览 8提问于2019-01-12得票数 1
2回答
我正在使用项目反应器从使用rest的web服务加载数据。这是与多线程并行完成的。我开始遇到web服务的速率限制，所以我希望每秒最多发送10个请求，以避免出现这些错误。使用zipWith(Mono.delayMillis(100))？还是有更好的方法？
谢谢
浏览 2提问于2017-05-05得票数 10
1回答
我编写这段代码是为了派生出大量的WebClients (受reactor.ipc.netty.workerCount限制)，立即启动Mono，然后等待所有Monos完成： .cache()); } } catch (E
浏览 1提问于2018-03-21得票数 0
当WebClient用错误的令牌异步调用外部api (具有不同查询参数)时，前几次返回401未经授权，控制流以Exceptions.CompositeException停止。我们在WebClient实例中添加了一个过滤器，用于检查4xx和5xx响应状态代码，以引发自定义异常 return ExchangeFilterFunction
.ofResponseProcessor(response -> response.statusCode().is
浏览 8提问于2022-05-12得票数 1
回答已采纳
1回答
我在Rxjava中有我的代码，我想要更改它的反应器项目。data= client.getObject(ids, filters).getData(); });如何使用Flux / Mono我应该使用什么(Flux/ Mono)？
基本上，我想知道如何像Observable一样将Map存储到Flux，或者我应该使用Mono
浏览 3提问于2018-06-16得票数 5
我检索地址文档列表的Mono列表，并使用这个地址文档的Mono列表形成街道地址(WithStreet)，如下所示： }
当我执行上面的代码时，它会抛出一个“/blockFirst()/blockLast()nio阻塞，这在线程反应器-HTTP-nio-2中是不支持的”。此响应将在响应实体的代码中进一步使
浏览 2提问于2020-06-14得票数 0
回答已采纳
我们得到一个Mono，它处理一些操作(例如数据库更新)，并返回一个值。for (Mono mono : specialList) {
Object value =
浏览 16提问于2022-05-10得票数 1
另外，我需要等待所有请求的终止。我开发了以下代码： .map(jobStatusBunch ->Collectors.toList());Mono<
浏览 7提问于2019-11-20得票数 2
3回答
它正在编译，但在运行时，它永远停留在转换阶段(即Mono.from { obs })。fun saveScopeId(scopeId: ScopeId): Mono<ScopeId> { return Mono.from<ScopeId> { obs }
}
浏览 28提问于2020-07-07得票数 1
我对Mono和Flux很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集Mono的列表，我需要从下游API返回的有效负载列表，这是我从Mono获取的。如果这是绑定到HTTP请求，则基本上是在触发反应性管道，而不保证资源或完成。调用订阅会触发管道，但不会等到管道完成后再调用
var result = new ArrayList<List<>>(
浏览 36提问于2022-06-04得票数 2
回答已采纳
我有一个多模块项目，我想按照maven反应器排列它们的顺序来获得artifactId的列表。这可以通过maven命令行来完成吗？到目前为止，我已经获得了部分信息但这是打印项目名称，而我想要的是artifactId。
浏览 3提问于2015-08-31得票数 2
1回答
我有List<Mono<String>>名单。每个Mono表示我等待I/O以获得结果的API调用。问题是，有时有些调用不返回任何内容(空字符串)，在这种情况下，我需要再次重复它们。<Map<Any, Any>>).block()}val secondAskForItem = firstAskForItemsRetrieved}
然后再次阻塞每个项目。&
浏览 0提问于2018-04-12得票数 1
回答已采纳
项目反应器很棒，我可以很容易地切换一个线程来处理另一个线程上的某些部分，但我已经深入研究了Schedulers.fromExecutorService()方法，这个方法每次都会分配新的ExecutorServiceMono<String> sometext() {.fromCallable(() -> "" )
.subscribeOn(Schedulers.newParallel("my-customMono.fromCallab
浏览 0提问于2021-05-08得票数 0
我有三个电话： .uri('uri') .retrieve()添加到Mono列表我合并了所有的响应，并寻找第一个项目calls)
浏览 0提问于2018-11-14得票数 0
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
