我想以一种非阻塞的方式调用一个API Rest，之后，在订阅方法中，调用另一个API Rest。 第一个调用执行正确，subscribe方法也执行正确。我的问题是，在订阅中，我如何请求另一个API Rest？@Autowired
Mono<UserR
浏览 66提问于2019-04-10得票数 0
我遇到的情况是，我无法理解Kotlin在 对象上使用的方法。当从apply方法中调用mono对象的方法时，被调用的Mono方法根本不响应。示例不使用应用(按预期工作)： .just(1) println("doOnSuccessOrErr
浏览 0提问于2019-01-12得票数 0
我有一些受表单身份验证保护的REST服务，在调用业务REST服务之前，我必须调用通过Security提供的'login‘URL，传递我的凭据，并将返回的Cookie放到对其他REST服务的进一步调用中。下面是对REST业务服务调用的片段.<String> t = fetch(apiManagementWrapper, httpRequest);
}
浏览 2提问于2018-01-02得票数 8
回答已采纳
我经常需要在onSubscribe和onFinally上执行一些逻辑，这可以通过 returnSystem.out.println("ON FINALLY");}List<String> result = Mono.fromCa
浏览 3提问于2018-08-27得票数 1
回答已采纳
我必须同时执行多个API调用，它们是相互独立的： .post()().flatMap(Mono::error);如何在单独的对象中获得上述api调用的响应，同时并行执行它们？另外，在执行上述调用并将数据放在单独的对象(例如Response1、Response2、Resp
浏览 25提问于2022-03-15得票数 1
回答已采纳
1回答
请考虑以下代码： Mono.just(1)// .map(Main::return_void) // is not ok
.subscribe
浏览 0提问于2019-07-10得票数 7
回答已采纳
： return Mono.error(new Exception("My error"));测试代码非常简单:我只需调用myMethod-3.4.18.jar:3.4.18] at reactor.core.
浏览 4提问于2022-06-28得票数 0
在方法A中，我必须调用b.subcribe()。如果没有它，方法B将不会执行。在不使用subscibe的情况下调用它的有效方法是什么？我觉得subcribe在这里不对 public static void main(String[] args) { Mono<Integer> a = t.A();
System.out.printl
浏览 9提问于2021-04-30得票数 0
1回答
在之前的一次前端采访中，我被问到“如何在angular2服务器中调用restful api”。我说的是使用http。但面试官似乎对这个答案并不满意。正确答案是什么？谢谢你！！
浏览 3提问于2018-01-11得票数 0
1回答
我有一个需求，在其中我需要执行一个由3个方法调用组成的序列，每个调用都返回一个Mono。Mono<WeightResponse> weightService() Mono<DispatchResponse> dispatchService(PriceResponse pr)
这三个方法调用<
浏览 3提问于2022-04-13得票数 0
回答已采纳
我在reactor中有一个Mono<String>对象。如何从该对象获取字符串值？我知道我可以这样做:对于Mono<String> userName，我可以这样做：但这将直接打印值。我想将这个字符串值存储到另一个变量中，这样我就可以将该变量传递给其他一些函数。如何提取此值？
浏览 4提问于2019-08-05得票数 6
回答已采纳
我的控制器将一个Mono (称为"limit")作为服务参数传递给我的服务。Mono在订阅时发出一个Integer，服务使用该Integer完成其工作，该Integer返回一个Flux。在我的服务方法中，我需要订阅mono --但我需要“在”我的服务方法(它对其他端点进行web客户端REST调用)之前这样做，因为在REST调用中需要Limit值。现在，我知道subscri
浏览 94提问于2021-04-21得票数 0
2回答
问题1: public Mono<String> doSome(String str){ return getValueFromRedis(key); return Mono.fromCall
浏览 0提问于2019-06-30得票数 3
回答已采纳
我正在尝试调用微服务应用程序中的外部服务，以便在启动其他计算之前并行地获取所有响应并组合它们。我知道我可以对每个Mono对象使用块()调用，但这将违背使用反应性api的目的。initialization"); });
System.out.println(r
浏览 3提问于2019-10-17得票数 4
回答已采纳
我想重新抛出我的异常从我的“数据库”REST到我的“后端”REST，但我失去了原始异常的消息。这就是我通过Postman从我的“数据库”REST中获得的信息： "timestamp": "2020-03-18T15:19:14.273+0000", "error": "Bad Request",
"message": &q
浏览 2提问于2020-03-18得票数 3
回答已采纳
我对Java中的反应性流比较陌生。我正忙于研究如何在反应性流中测试和验证对象协作。我使用弹簧测试和反应堆测试库进行TDD测试。assertThat(request.getMethod()).isEqualTo("GET"); }).verifyComplete
浏览 2提问于2020-12-18得票数 1
回答已采纳
4回答
我在一些SpringWeb通量代码中遇到了Mono.defer()“创建一个Mono提供程序，它将为下游的每个订阅者提供一个目标Mono订阅服务”
请给我一个解释和一个例子
浏览 0提问于2019-05-02得票数 60
回答已采纳
我需要对rest进行http调用(我只能在整个流程中进行一次)。对于响应，我需要计算两件事：public void computeData(String id) {
httpClient.getData(id) // Returns a Mono<Data>我的问题是，如何才能以一种反应和非阻塞的方式来完成这个流，并且只对rest</em
浏览 1提问于2020-06-27得票数 1
回答已采纳
我们使用的是Spring Data reactive，当我们调用findAll时，我们会收到一个Flux<T>，我们希望在API中公开这个响应，但我们的API结构是 { "items": [ ... ]
} 因此，我们希望将其公开为Mono<<Response<T>> public class Response<T>
浏览 60提问于2020-06-19得票数 1
回答已采纳
1回答
public Mono<String> process() { .map(String::toLowerCase)
.subscribeSchedulers.fr
浏览 28提问于2019-12-08得票数 1
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号