项目反应器:等待Mono列表完成
项目反应器是一种用于等待Mono列表完成的工具。在编程中，Mono是指一个只包含一个元素的列表。项目反应器的作用是在所有的Mono都完成后，触发一个回调函数或执行一些特定的操作。
项目反应器的分类：
- 同步反应器：当所有的Mono都完成后，立即触发回调函数或执行操作。
- 异步反应器：当所有的Mono都完成后，将回调函数或操作放入任务队列中，等待执行。
项目反应器的优势：
- 提高代码的可读性和可维护性：通过使用项目反应器，可以将多个异步操作的处理逻辑组织成一个清晰的流程，提高代码的可读性和可维护性。
- 提高程序的性能：项目反应器可以并行处理多个异步操作，提高程序的性能和响应速度。
- 简化异步编程：项目反应器可以简化异步编程的复杂性，避免回调地狱和线程同步的问题。
项目反应器的应用场景：
- 并发请求的处理：当需要同时发送多个请求，并在所有请求完成后进行下一步操作时，可以使用项目反应器来等待所有请求完成。
- 多任务的协调：当需要同时执行多个任务，并在所有任务完成后进行下一步操作时，可以使用项目反应器来等待所有任务完成。
- 异步数据的处理：当需要对多个异步获取的数据进行处理，并在所有数据获取完成后进行下一步操作时，可以使用项目反应器来等待所有数据获取完成。
推荐的腾讯云相关产品： 腾讯云函数计算（SCF）：腾讯云函数计算是一种事件驱动的无服务器计算服务，可以帮助开发者更轻松地编写和管理无服务器应用程序。通过使用腾讯云函数计算，可以方便地实现项目反应器的功能。了解更多信息，请访问：腾讯云函数计算
腾讯云消息队列（CMQ）：腾讯云消息队列是一种高可靠、高可用的消息队列服务，可以帮助用户实现消息的异步传输和解耦。通过使用腾讯云消息队列，可以方便地实现项目反应器的功能。了解更多信息，请访问：腾讯云消息队列
腾讯云云函数工作流（SCFW）：腾讯云云函数工作流是一种全托管的工作流服务，可以帮助用户以图形化方式编排和执行多个云函数。通过使用腾讯云云函数工作流，可以方便地实现项目反应器的功能。了解更多信息，请访问：腾讯云云函数工作流
相关·内容
1回答
我编写这段代码是为了派生出大量的WebClients (受reactor.ipc.netty.workerCount限制)，立即启动Mono，然后等待所有Monos完成：
List<Mono<List<MetricDataModel>>> monos = new ArrayList<>(metricConfigs.size());
for (MetricConfig metricConfig : metricConfigs) {
try {
monos.add(extractMetrics.qu
浏览 1提问于2018-03-21得票数 0
我的WebFlux控制器： import reactor.adapter.rxjava.RxJava3Adapter;
import reactor.core.publisher.Mono;
import io.reactivex.rxjava3.core.Single;
@RestController
@RequestMapping("/test")
public class MyController {
@GetMapping("/mono")
public Mono<String> getMono(ServerWebExchang
浏览 23提问于2021-04-25得票数 0
回答已采纳
1回答
我使用的是项目反应堆，我想执行以下操作：
@Override
public void run(ApplicationArguments args) {
Flux.from(KafkaReceiver.create(receiverOptions)
.receive()
.map(this::getObject)
.flatMap(this::iterateElasticWrites)
浏览 6提问于2022-04-17得票数 3
回答已采纳
我已经创建了一个String Monos List<Mono<String>> myList的列表。现在我需要将它们连接在一个大字符串中。 当我初始化StringBuilder并异步更新它时，可能会返回空行。 //method body....
StringBuilder builder = new StringBuilder();
myList.forEach {
mono ->
mono.map{ str -> builder.append(str)}
}
return builder.toString() //<- is
浏览 47提问于2019-06-20得票数 1
回答已采纳
我想做如下的事情。在Mono.fromCallable中，我运行一些块逻辑，然后根据值返回Mono.empty()或值，从而触发映射或defaultIfEmpty。
Mono.fromCallable(() -> {
double number = Math.random();
if (number < 0.5) {
return Mono.empty();
}
return number;
浏览 4提问于2020-08-10得票数 3
回答已采纳
1回答
我是新来的反应堆核心，过去做过二郎。
希望有个简短的问题。
假设我们发送了一个消息'A‘，然后期望在x分钟内得到响应。如果在x分钟内没有响应，我们将运行回退例程。
这可以使用Flux或Mono与方法超时(持续时间，回退)来完成。
public final Mono<T> timeout(Duration timeout,
Mono<? extends T> fallback)
Switch to a fallback Mono in case no item arrives within the giv
浏览 0提问于2018-04-13得票数 0
回答已采纳
2回答
我知道这个问题以前提过几次，但我找不到一个简单的例子的答案：
是否有免费工具将小型.NET C#应用程序编译为本机可执行文件？
到目前为止，我发现的是代价高昂的工具，这些工具可以剥离.NET框架并将其编译到可执行文件中，但在我们的例子中，这是不必要的。安装.NET框架是没有问题的，我们只想预编译一个C#项目，这样用户出于安全原因就不能解压缩IL代码。.NET捕获器是不够的，因为我们有敏感的代码部分。
mono不是一个选项，因为它需要在目标机器上安装mono，这是我所理解的。
Ngen.exe似乎是最接近我们需要的文件，但是我们如何分发输出文件呢？它似乎也包含IL代码，因为它说“每当在不兼容的环
浏览 3提问于2013-05-13得票数 0
1回答
Monix任务中为空
、、、
项目反应器有一些类似Mono.emptyT的东西，它可以在特殊情况下处理，当你没有任何东西时，它被评估。在Monix Task中有类似的东西吗？ def getItemFromList[T](inp: Mono[List[T]]): Mono[T] = {
val moList = inp.defaultIfEmpty(List[T]())
moList.flatMap[T]((list: List[T]) => {
if (list.isEmpty) Mono.empty[T]()
else Mono.just(list.head)
}
浏览 19提问于2019-03-15得票数 0
我有一个java webclient代码，我将其响应转换为Mono。我想对api调用进行迭代，直到Mono响应符合特定条件。当然，我不想迭代到无穷大。我想每隔5秒迭代一次，直到30秒。到目前为止，我已经尝试过了
client.get()
.uri("https://someUri")
.retrieve()
.bodyToMono(Response.class)
.delayElement(Duration.ofSeconds(5))
浏览 94提问于2020-05-05得票数 0
回答已采纳
我想知道如果你订阅了一个带有几个变种的Mono.error(new OutOfMemoryError("hello world"))会发生什么。
这些测试对我来说通过了(使用reactor-core 3.4.3)：
@Test
public void oom() {
Mono.error(new OutOfMemoryError("hello world")).subscribe();
}
@Test
public void oom_thenReturn() {
try {
浏览 6提问于2021-11-10得票数 0
2回答
ScriptEngineManager scriptEngineMgr = new ScriptEngineManager();
ScriptEngine jsEngine = scriptEngineMgr.getEngineByName("nashorn");
Mono.fromRunnable(() -> {
System.out.println("11111");
try {
System.out.println(
浏览 19提问于2020-06-04得票数 0
回答已采纳
我正在使用进行REST调用。我在3000毫秒上配置了连接超时，因此：
WebClient webClient = WebClient.builder()
.clientConnector(new ReactorClientHttpConnector(options -> options
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)))
.build();
return webClient.get()
.uri("http://localhost:8081/resource"
浏览 0提问于2018-03-10得票数 5
回答已采纳
我正在尝试将一个文件上传到S3，但是JVM说我在代码片段中有一个线程阻塞方法调用，其中线程在调用file.readAllBytes()时不应该被阻塞，那么有什么方法可以使这个方法与file.readAllBytes或Mono异步呢？或者其他解决问题的方法？
private Mono<Boolean> uploadFile(InputStream file, String bucket, String name) {
try {
return uploadAdapter.uploadObject(bucket,name,file.readAll
浏览 3提问于2021-12-27得票数 5
我在用openapi发生器做gradle。
配置：
task generateSalesOffersApi(type: org.openapitools.generator.gradle.plugin.tasks.GenerateTask){
generatorName = "spring"
inputSpec = "${projectDir}/src/main/resources/my-contract.yaml".toString()
outputDir = "${buildDir}/generated".toStri
浏览 2提问于2020-03-25得票数 3
如何有条件地执行运算符？
我有一个返回Mono<Void>的方法。它还可以返回错误信号。我想要使用then运算符(或任何其他运算符)，仅当前一个操作完成时没有出现错误信号。
有人能帮我找到合适的供应商操作员吗？
public static void main(String[] args) {
Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL
.flatMap(s -> firstMethod(s))
.then(se
浏览 0提问于2019-08-29得票数 3
1回答
我运行了以下代码：
Mono<Void> mono = Mono.empty();
System.out.println("mono.block: " + mono.block());
它会产生：
mono.block: null
不出所料。换句话说，如果Mono已经完成，调用block将立即返回。
另一个例子，类似于真实世界的场景。我有一个源流，例如：
Flux<Integer> ints = Flux.range(0, 2);
我创建了一个可连接的flux，我将使用它来允许多个订阅者：
ConnectableFlux<Integer&
浏览 1提问于2019-04-13得票数 0
我已经开始学习Spring web flux了。我目前的需求是在我的项目中使用Spring web flux和AMQP。这个项目是使用rabbitmq发布-订阅AMQP消息传递和项目没有网络dependency.This项目将在纯粹的后端工作。
下面是我的demo服务文件，这个服务在消息负载中获取所需的数据，然后服务将根据负载数据进行处理，并完成需要的任务。
public class HandlerService {
@RabbitListener(queues = "${amqp.queue}")
public void consumeMessageFrom
浏览 18提问于2020-03-03得票数 0
我知道在反应性流中使用阻塞操作时，我们应该使用Publisher<Object>.publishOn(Schedulers.elastic).subscribe(//blocking operations go here)
我知道，当我的发布者发布一个项目列表(对于ex:通量)时，未来的项目不必等待当前项被阻塞操作阻塞，这是有意义的。但万一发生Mono，是否有必要呢？因为只有一个东西会在我的管道里流动。
PS。我使用的弹簧引导2反应通量控制器，类似于这样。
@RestController("/item")
public Mono<Response> sa
浏览 4提问于2017-11-07得票数 2
回答已采纳
我有一个方法，它得到重定向url，然后重定向到那个url。
private Mono<Void> redirectToUrl(ServerHttpResponse response, String status) {
String queryParameter = "?status=" + status;
return getRedirectUrl(queryParameter)
.flatMap(url -> {
response.setStatusCod
浏览 1提问于2019-11-21得票数 3
回答已采纳
1回答
该接口使用以下"application/json"主体类型构造进行响应：
{
"transactions": [
{
"transaction": "1",
},
{
"transaction": "2",
},
{
"transaction": "3",
}
]
}
基本上我把它映射到..
public class Transactions {
pr
浏览 6提问于2020-02-11得票数 2
回答已采纳
我们最近开始尝试spring boot 2.0。具有以下处理程序代码：
@Component
public class DataStreamHandler {
public Mono<ServerResponse> pipeEvent(ServerRequest request) {
Mono<String> reqBody = request.bodyToMono(String.class);
String body = reqBody.block();
System.out.println(body);
浏览 0提问于2018-02-19得票数 1
2回答
我有以下代码，用于从反应性spring存储库获取列表：
Mono<List<ActivePairs>> list = activePairsService.findAllOrdered().collectList();
ActivePairs obj = new ActivePairs().pair("All");
我想在清单的开头增加项目：
我试过：
list.mergeWith(new ActivePairs().pair("All"));
但我明白：
Required type: Publisher
<? extends ja
浏览 2提问于2022-06-15得票数 1
回答已采纳
我使用web flux创建了一个spring boot应用程序。我在控制台中记录了我的结果。我看到我使用Mono创建的方法是在parallel-1线程上执行的，但是我看到了这个actor-tcp-nio-1，Mono的方法在其中执行。这个线程是什么？为什么它不在并行-1线程上执行。 控制台日志 2021-04-04 23:27:04.356 INFO 7225 --- [ parallel-1] reactor.Flux.UsingWhen.1 : onSubscribe(FluxUsingWhen.UsingWhenSubscriber)
2021
浏览 111提问于2021-04-05得票数 0
我有一个这样的课程
public class Person {
private String name;
private String age;
private Boolean student;
...
//
getters and setters
}
public class PersonDto {
private List<Person> persons
private Person president
//
getters and setters
}
并从外
浏览 4提问于2021-07-08得票数 0
我写了这段代码：
Flux.range(0, 300)
.doOnNext(i -> System.out.println("i = " + i))
.flatMap(i -> Mono.just(i)
.subscribeOn(Schedulers.elastic())
.delayElement(Duration.ofMillis(1000))
)
.doO
浏览 5提问于2020-08-11得票数 4
回答已采纳
我想为每个队列元素执行http请求。这些请求应该并行调用。
另外，我需要等待所有请求的终止。
我开发了以下代码：
List<Mono<MyResponseDTO>> monoList = queue.stream()
.map(jobStatusBunch -> webClient
.post()
.uri("localhost:8080/api/some/url")
.b
浏览 7提问于2019-11-20得票数 2
由于某些原因，doAfterSuccessOrError方法中的不能从上游获得(填充)。我已经尝试过使用Mono.subscriberContext()访问它(参见代码片段)。我希望它能出现，但由于某种原因并没有出现。我做错了什么吗？
public class LoggingRequestExchangeFunction implements ExchangeFilterFunction {
private final Logger log = LoggerFactory.getLogger(getClass());
@Override
public Mono<
浏览 19提问于2019-08-04得票数 1
回答已采纳
我正在使用Xamarin为Android开发一个类库。如何在库项目中添加对Mono.Android的引用？Mono.Android不在可用程序集列表中。
浏览 0提问于2014-02-03得票数 4
回答已采纳
我正试着从集合中获得一份文件。文档可能不存在，如果使用null，则返回默认值。
我的查询和转换：
return template.findOne(Query().addCriteria(Criteria.where("id")), DeviceSettings::class.java)
.map {
when (it) {
null -> {
defaultSettings(clock)
浏览 1提问于2018-04-29得票数 0
回答已采纳
我对Mono和Flux很陌生。我正在尝试加入几个下游API响应。这是一个传统的阻塞应用程序。我不想收集Mono的列表，我需要从下游API返回的有效负载列表，这是我从Mono获取的。但是，有时返回给控制器的“结果”只有部分或没有下游API响应。正确的方法是什么？我读过几篇的文章
您不应该在web应用程序中的任何地方调用订阅。如果这是绑定到HTTP请求，则基本上是在触发反应性管道，而不保证资源或完成。调用订阅会触发管道，但不会等到管道完成后再调用
我应该使用CompletableFuture吗？
在我的服务中，我试图
var result = new ArrayList<List&l
浏览 36提问于2022-06-04得票数 2
回答已采纳
3回答
尝试在couchbase中插入，并且具有可观察的返回类型，但需要单声道，因此执行此操作。它正在编译，但在运行时，它永远停留在转换阶段(即Mono.from { obs })。 fun saveScopeId(scopeId: ScopeId): Mono<ScopeId> {
val obs = scopeRepository.couchbaseOperations.insert(scopeId)
return Mono.from<ScopeId> { obs }
}
浏览 28提问于2020-07-07得票数 1
我不知道如何使用当时的项目反应堆操作员。我不太理解这个操作符的javadoc。谁能向我解释这件事？有了一些代码示例就很好了。我自己写了一个例子如下：
public class Test11 {
public static void main(String[] args) {
Flux flux = Flux.just(1, 2, 3);
Mono<Void> mono1 = flux.then();
mono1.subscribe(null, null, () -> System.out.println("yes
浏览 0提问于2021-05-10得票数 0
回答已采纳
我正在工作的项目是使用。我遇到了一个很奇怪的问题。细节是，有些代码完全是以反应堆的方式编写的( Flux/Mono管道夫妇)，但是，在内部发布者中，我必须调用一个方法，其中包含"Mono.block()“。
奇怪的是，整个服务会完全卡住，当我捕获一个线程转储时，我看到了所有那些"nioEventLoopGroup-*“线程被挂起。
一个有趣的事实是，如果我利用一个“简单”线程(新线程(..))要调用这个方法(里面有.block )，一切都很好。
所以我的问题是，那些"nioEventLoopGroup-*“线程不允许调用任何阻塞代码。
很抱歉问了一个愚蠢的问题，但它现在
浏览 3提问于2022-09-09得票数 0
3回答
来自维基百科的文章：
反应器设计模式是一种事件处理模式，用于处理由一个或多个输入并发传递给服务处理程序的服务请求。
它列举了几个示例，例如nodejs、twisted、eventmachine
但据我所知，上面是流行的事件驱动框架，所以让它们也成为一个反应器模式框架？
如何区分这两者？还是说它们是一样的？
浏览 42提问于2012-02-04得票数 72
回答已采纳
是否有可能将PathPattern作为Bean在SpringBoot web中获得并在用户代码中重用？
例如，如果url为：/user/1990/lily，它将返回Controller：/user/{year}/{name}上的url。
说：
模式在启动时进行解析，并在运行时重新使用，以实现有效的URL匹配。
需要一个uriTagValue来避免基数爆炸，
public class Application {
public static void main(String[] args) {
Metrics.globalRegistry
浏览 33提问于2022-07-31得票数 0
1回答
我是个新手，负责启动网络流量和反应堆，我希望在发生某些特定异常时有一个后备机制，根据我的研究，onErrorResume方法可以做到这一点，但是它不会被调用，我会得到500个内部服务器错误，而不是触发和防止这个错误的回退。
注:我使用的是弹簧网络流量，这意味着它对反应堆项目的正常行为做了一些改变。
public Mono<Date> getExpirationDateFromToken(String token) {
return getAllClaimsFromToken(token)
.onErrorResume(ExpiredJwtExcept
浏览 4提问于2020-03-22得票数 1
回答已采纳
我有2 Mono<T>，这是从那里得到的，有两个不同的来源，比如KAFKA。
我的目的是将和 Mono合并成一个Flux<T>。1
然后在public final Mono<T> reduce(BiFunction<T,T,T> aggregator)中使用Flux方法来创建最终的Mono (因为上述两个Mono的响应时间可能有所不同)。2
方法：
在contact上使用的方法有很多，如zip、zipWith、Flux。如何得出正确的使用方法(两个Mono到Flux转换，即1)。
这个REDUCE方法真的正确吗，或者还有什么可以做的来即兴发挥它(
浏览 5提问于2021-05-09得票数 1
我有这个方法
private Mono<String> getToken(String id){
....
}
和调用者
List<String> tokens = new ArrayList<>();
getToken(id).map(s -> tokens.add(s)).then();
它不会将返回的token添加到列表中，为什么这个管道永远不会完成，并且返回的token永远不会填充到列表中？
我已经尝试过subscribe()和flatMap()，但仍然存在问题。我设法将令牌填充到列表中的唯一方法是使用block()，这反过来又抛出了另一个异常
浏览 3提问于2021-08-06得票数 0
我正在使用Spring WebClient来调用rest服务。post调用的代码如下所述。 Mono<ClientResponse> response = client.post()
.uri(uriBuilder -> uriBuilder.build())
.headers(httpHeaders -> httpHeaders.setAll(getHeaders()))
.body(BodyInserters.fromPu
浏览 232提问于2019-12-20得票数 8
我有三个项目，分别存储在三个不同的存储库中。它们中的每一个都是单独的mvn项目。我想知道是否有一种方法可以将三个报告聚合到一个报告中？
我看了一下cobertura聚合函数。但它似乎只能处理项目的子模块。
有人有什么建议吗？
浏览 0提问于2013-11-05得票数 5
可以在以下位置阅读：
如果修改了系统时间(例如，如果您的操作系统是Linux，则使用deadline_timer命令)，使用deadline_timer::expires_at()实现的定期超时的日期可能会失败(如中的示例)。
现在有没有一种简单而合适的方法来执行这个操作，使用Boost？我不想使用deadline_timer::expires_from_now()，因为我可以验证它的准确性不如“手动”更新过期时间。
作为时间解决方案，我决定在设置新的expires_at值之前，计算从now()到expires_at()之间的时间段。如果它是周期性延迟的两倍以上，那么我会异常地使用expir
浏览 5提问于2013-02-13得票数 9
回答已采纳
1回答
我已经将我的电话呼叫列表保存到一个数据库中，现在我想要从这个数据库创建一个ListView。我已经写好了这段代码。但这是行不通的。我的密码怎么了？
database_helper.dart
..。
Future<List<Map<String, dynamic>>> queryAllRows() async {
Database db = await instance.database;
return await db.query(table);
}
..。
my_home.dart
..。
FutureBuilder(
浏览 3提问于2020-06-20得票数 1
我想同时给两个不同的服务打网络电话。最后，我将2个Response对象压缩到一个流中。我正在使用一个Callable，但我不确定我是否用正确的方式来做这件事。似乎我仍然会被第一次get()调用Future所阻塞，对吗？谁能告诉我我是不是在正确的轨道上？到目前为止，这就是我所拥有的：
// submit the 2 calls to the thread pool
ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
Future<
浏览 11提问于2022-04-29得票数 2
回答已采纳
我目前正在研究Twisted框架，将其作为实现基于网络的备份应用程序的一种方式，我希望实现一些我在网上找不到的示例。
我计划使用实现该系统，但我还需要一种将二进制文件从客户端传输到服务器的方法。我希望能够在PB上调用一个方法，然后使用某种UID通过单独的数据通道发送文件。
之所以有这两个独立的通信通道，是因为我想让客户机成为多线程的(一个线程扫描目录树，而另一个线程将更改后的文件传输到服务器)。
使用Twisted可以做到这一点吗？我读到过，让多个线程在一个反应器上调用方法是个坏消息，那么这个架构注定要失败吗？
我很感激任何正确方向的指点，正如我提到的，我仍然在研究可能性-但我计划在这个项目中
浏览 1提问于2010-10-18得票数 2
回答已采纳
我有一个HTTP服务，它公开一个GET端点，该端点通过TCP连接到一个简单的echo服务器。HTTP服务正在Netty上运行。 @RestController
public class OurTcpClient {
private Connection connection;
@GetMapping("echo1")
public Mono<String> echo(@RequestParam("value") final String value) {
this.connection.outbound(
浏览 41提问于2020-04-14得票数 0
回答已采纳
1回答
考虑代码示例：
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.reactive.function.client.WebClient;
import reactor.core.publisher.Mono;
import java.time.Duration;
import static com.google.common.collect.Immutabl
浏览 1提问于2018-09-04得票数 2
当我试图添加对mono2.8项目的引用时，System.Web.ApplicationServices不会出现在我的包列表中。知道为什么这个会丢失吗？
更新
再看一看，我在我的System.Web.ApplicationServices.dll文件夹中找到了/usr/lib/mono/4.0/。因此，我想它已经安装好了，只是由于某种原因，它在MonoDevelop 2.4中没有显示为一个选项。
更新2
直接从/usr/lib/mono/4.0/引用dll确实允许我成功地构建项目。但是，我仍然想知道为什么我不能在MonoDevelop中显示出我可以引用的“包”，以及如何修复它，以便我以标准的方式
浏览 1提问于2010-11-09得票数 1
回答已采纳
我有一个服务，它将数据流流到第二个服务，该服务接收对象流并将它们保存到我的MongoDB中。在我从流服务获得的Flux对象上的订阅函数中，我使用了来自ReactiveMongoRepository接口的save方法。当我尝试使用块函数并获取数据时，我会得到以下错误：
2019-10-11 13:30:38.559 INFO 19584 --- [localhost:27017] org.mongodb.driver.connection : Opened connection [connectionId{localValue:1, serverValue:25}] to
浏览 4提问于2019-10-11得票数 5
回答已采纳
我正在开发一个带有spring云的网关，我需要拦截消耗Oauth的请求，然后获得响应并添加带有jwt值的报头(响应为Ouath)。
我的过滤代码：
@Autowired
private IConsumoInstrospectService consumoIntrospect;
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
Mono<ResponseIntrospectDTO> rep = consumoIntros
浏览 3提问于2021-11-15得票数 1
1回答
我有一个返回Mono<Result>的规则列表，我需要执行它们，并返回另一个带有每个函数的结果的Mono列表。
Mono<List< Rule>>到Mono<List< RuleResult>>
我有这个，但阻止执行对我来说是不正确的：
List<Rule> RuleSet
...
Mono<List<RuleResult>> result= Mono.just(RuleSet.stream().map(rule -> rule.assess(object).block()).collect(
浏览 8提问于2020-07-23得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
