1回答
我正在尝试实现以下简单的命令式逻辑： boolean saveImperative(final List list) { return false;} 以声明的方式使用Project Reactor，这就是我能够实现的result = save(list).block();}
priv
浏览 27提问于2020-01-17得票数 1
回答已采纳
3回答
它正在编译，但在运行时，它永远停留在转换阶段(即Mono.from { obs })。fun saveScopeId(scopeId: ScopeId): Mono<ScopeId> { return Mono.from<ScopeId> { obs }
}
浏览 28提问于2020-07-07得票数 1
Spring boot 2.1.5项目反应堆3.2.9 在我的webflux项目中，为了传递一些值，我广泛地使用了反应器上下文。@Component @Override WebFilterChain webFilt
浏览 105提问于2019-06-13得票数 5
回答已采纳
在没有根项目的情况下，如何在多个maven项目上执行ad-hoc reactor构建？这在maven2中曾经是可能的，通过调用带有'-r‘选项的mvn命令，该命令将从工作目录递归地搜索项目，并在反应器中组织它们以正确的顺序构建，即使这些项目没有共享公共的父pom.xml。可以选择使用maven.reactor.includes和maven.reactor.excludes选项明确包含或排除某些项目。我意识到遗留的反应器模式已经从maven3中
浏览 0提问于2011-04-22得票数 6
回答已采纳
我正在用Spring webflux和项目反应器在一个家庭项目中试用kotlin。我正在尝试对H2数据库进行阻塞调用，因此我按照建议使用了fromCallable方法。fun updateUser(req: ServerRequest): Mono<ServerResponse> = .doOnError { ServerResponse.notFound().build() }
fun updateUser(u
浏览 119提问于2019-05-24得票数 2
回答已采纳
我开始使用项目反应堆。有人知道如何将线程局部变量从一个线程传递到另一个线程吗？我在Hooks.java上看到了一些方法，但不知道推荐的方法是什么。有没有人可以给我一些文档或者代码片段告诉我怎么做。
浏览 0提问于2017-04-30得票数 0
1回答
我试图弄清楚如何获取一个Flux，它是一个输入数据序列，并行地通过一个阻塞调用运行它们，这个阻塞调用可能会重新排序该序列，然后通过第二个单线程阻塞调用运行重新排序的数据。我试图做的事情的最终目的是，并行算法是一种协商一致的算法，它将决定数据输入的实际顺序。单线程写入是按照协商一致算法确定的顺序模拟事物的处理。(in)) }我一直试图通过这些方法获取整数的通量，并以某种方式映射或flatMap，但是我无法获得任何可以记录的内容我希
浏览 0提问于2019-11-05得票数 2
回答已采纳
我对项目反应器库和反应式编程非常陌生，并尝试实现像flatmap，flatMapIterable，subscribe等函数。现在，当我尝试使用函数1的o/p时，我看不到值，只看到Mono<>或Flux<>。下面是更多解释的代码片段 var result = employerService.getEmployee("Active") // return value is Mono<GetEmployeeStatusListRes
浏览 16提问于2019-01-02得票数 2
1回答
基本上，我在Spring中制作了一个队列处理器，并希望使用反应器来实现异步。我已经做了一个需要永远循环的函数，因为它是从队列中提取的函数，然后将项目标记为已处理。下面是工作的阻塞版本，订阅返回一个Mono manager.Subscribe().block()我不知道如何将它转换成一个Flux，我已经看过一个间隔，生成，以下是使用AWS v2订阅方法所做的工作： return Mono.
浏览 2提问于2018-04-20得票数 1
回答已采纳
下面是我的删除项目的控制器： public Mono<ResponseEntity> delete( .map(aVoid -> ResponseEntity.ok());
} itemService.delete(id)返回Mono<Void> 但是，当我成功删除一个项目时，它没有给出响应实体
浏览 85提问于2019-09-03得票数 5
回答已采纳
@RabbitListener(queues = VEHICLE_UPDATE_QUEUE) Mono.just例如，如果客户端代码返回一个Mono<Exception>，那么这将触发重试。同样，我可以有条件地触发重试到Mono<Exception>的映射。exists)
.flatMap(missing -> Mono.e
浏览 1提问于2020-07-29得票数 0
回答已采纳
我已经在MVC代码中这样做了，但是我不知道如何使用WebFlux(Library-项目反应器来实现反应性API)。主计长：
public Mono<ResponseEntity<JsonNode>> getData(@RequestHeader HttpHeaders header, GetDataRequest注意:这里不使用WebClient，只有Flux和Mono。
浏览 4提问于2021-06-25得票数 0
回答已采纳
2回答
所以我正在尝试用Mono构建一个C#项目。我想包含一个对System.Deployment的引用，条件是单编译器定义的__MonoCS__常量的存在或不存在。我想我可能必须添加一个单声道配置，它将定义一个单声道常量，然后我可以删除对System.Deployment的引用，并使用#if MONO command...but有条件地编译我需要的行。如果我可以简单地将Condition="Defined(__MonoCS__)"添加到有问题的行中并将其称为good，将会容
浏览 0提问于2012-09-29得票数 2
回答已采纳
1回答
Mono<Boolean> isRegistered(Student std);Mono<Boolean> isAvailable(Student std); 我想要一个逻辑，如果任何检查返回如下所示的false，它将停止流并抛出错误：return i
浏览 1提问于2022-10-13得票数 1
回答已采纳
如何有条件地执行运算符？ Mono.just("GOOD_SIGNAL")//It can also be a BAD_SIGNAL("SOME_SIGNAL"); private stati
浏览 0提问于2019-08-29得票数 3
是否可以有条件地使映射类型属性成为可选的？ 考虑一下这种类型 type Definition { defaultImplementation?: ImplementationType
} 以及它们的记录： type DefinitionMap = Record<string, Definition> 我想创建一个映射类型，如果提供了输入，它的实现是可选的，但如果没有提供，映射类型实现是必需的。Defini
浏览 34提问于2021-04-03得票数 2
回答已采纳
我正在处理一个遗留项目，在这个项目中，我必须实现一个接口，该接口有许多方法可以从redis查询各种对象。有时候，查询就像通过ID查询哈希一样简单，因此它只是对redis的一个调用来获取哈希。用生菜/反应器实现第一种方法很容易：
public <T extends CatalogInfo> Mono<String> getReactive(String id, Class<T> clazz,Publisher<String>...
浏览 4提问于2017-07-28得票数 3
回答已采纳
2回答
我需要用弹簧反应器以反应方式连接数据库。下面是我想要得到的场景->
2.然后连接到db并获得response2，同时提供response1参数。Join those two into single response and send back to the user as String由于所有对象都是唯一的，所以我计划使用MonoMono<Response2> r
浏览 0提问于2018-10-16得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
