3回答
我想在上一次返回Mono<Void>时调用该方法
@Override
public Mono<Void> sendEmail(EmailDto emailDto) {
return mailReactiveClient.sendEmail(message ->
createMessage(emailDto, emailDto.getBody(), message))
.doOnNext(saveNotificationLog(emailDto)); //it's not work
}
private void saveN
浏览 5提问于2018-07-25得票数 23
回答已采纳
考虑到以下情况：
Mono<Void> mono1 = Mono.fromRunnable(() -> {
System.out.println("sleep1");
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
throw new IllegalStateException(e);
}
System.out.println("mono1");
});
Mono<Void> mono2
浏览 8提问于2019-05-17得票数 2
回答已采纳
嗨，我有一个返回Mono<ResponseEntity<Void>>的API，该API将调用另一个返回Mono<ResponseEntity<Object>>的API，如何将结果从另一个API转换为Mono<ResponseEntity<Void>>？例如：
public Mono<ResponseEntity<Void>> api() {
return anotherApi()
.map(response -> ResponseEntity.ok().build())
浏览 8提问于2022-06-05得票数 0
回答已采纳
我的标题听起来令人困惑，所以让我用一些命令式伪代码来解释我想要做的事情 Mono<Void> func() {
Mono<MyThing> myThing = getMyThing();
if myThing is not empty:
return doSomething();
else:
return doSomethingElse();
} 这就是我在尝试进行反应性操作时遇到的问题： Mono<Void> filter(ServerWebExchange exchange, WebFilterChain chain) {
浏览 484提问于2021-03-31得票数 1
回答已采纳
我正在尝试从Objective-C端调用Unity C#脚本。使用void参数的函数有效。如果另一端的脚本是Javascript，则使用字符串参数的函数有效。
如果另一端的脚本为C#，则带有字符串参数的函数会崩溃。crash是一个BAD_EXEC。
我非常确定我没有正确地编组参数。在网络上确实没有太多关于这方面的文档。
我读过Embedding Mono，也看过Github上非常古老的例子。
类型和函数是这样声明的：
typedef void* MonoDomain;
typedef void* MonoAssembly;
typedef void* MonoImage;
typedef
浏览 0提问于2012-05-22得票数 1
回答已采纳
我的程序服务提供了一些返回Mono<Void>的删除方法，例如：fun delete(clientId: String) : Mono<Void>
在调用.delete("x")之后，我想向下游传播clientId以执行其他操作：
userService.get(id).map{ user ->
userService.delete(user.id) //This returns Mono<Void>
.map {
user.id //Never called!!!
}
.ma
浏览 7提问于2019-08-09得票数 3
回答已采纳
2回答
我正在编写一个插件系统，将Mono嵌入到我的C++程序for中。现在，我正在尝试向C++运行时公开一个C#函数，以便脚本可以从主程序调用C++函数。
这样做的方式如下：
mono_add_internal_call("Hello::MonoMsg",MonoMsg);
除了煮熟的两个例子外，我还有两个例子，它们都犯了同样的错误：
C:\Projects\MonoTestBed\main.cpp|34|error: invalid conversion from 'void (*)(MonoString*)' to 'const void*'
浏览 1提问于2013-02-02得票数 2
map函数中的返回值应该是MonoEmpty。
示例：
Mono<Void> empty = Mono.just("ping").map(s-> ????);
或者，如果我需要这个功能，模式应该是执行flatMap吗？
Mono<Void> empty = Mono.just("ping").flatMap(s-> Mono.empty());
浏览 0提问于2019-01-23得票数 0
回答已采纳
1回答
最近，我开始使用reactive开发Spring应用程序。我有两个问题。
Mono<Void>和 void有什么区别？
我有一个usecase，如下所示，我认为可以使用void或Mono<Void>来改进
@Service public class ABCService { public Mono getGreeting(String name) { Mono.just(NameValidator.validate( name) ) .map(isValid -> "Hello，“+name+.欢迎！)；}公共类NameValidator {公共静态布尔验
浏览 2提问于2021-09-13得票数 1
回答已采纳
Runnable用Java返回void。为什么Mono.fromRunnable返回Mono<T>而不是Mono<Void>
浏览 8提问于2022-08-18得票数 0
如何有条件地执行运算符？
我有一个返回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回答
我在弄清楚如何从C调用泛型方法(静态和非静态)时遇到了麻烦。
最大的罪魁祸首是调用泛型方法基本上是没有文档记录的，在mono存储库中没有示例，但在文档中提到这是可能的：
If you want to invoke generic methods, you must call the method on the "inflated" class, which you can obtain from the mono_object_get_class()
MonoClass *clazz;
MonoMethod *method;
clazz = mono_object_get
浏览 9提问于2014-03-09得票数 5
类似于，但我专门要求fixedDelay
我知道我不能仅仅使用Mono.subscribe()，因为延迟语义将无法工作。
我知道我可以使用Mono.delayElement，但我更喜欢使用注释驱动的方法，这种方法也允许使用允许SPeL表达式的fixedDelayString。
所以我的问题是是否有可能
@Scheduled(fixedDelayString="${interval}")
Mono<Void> generateKeys() {
return ...a mono...
}
现在我正在做这样的事情
@Service
public class JwksP
浏览 17提问于2022-05-10得票数 2
2回答
我使用反应性全局过滤器在网关响应中添加cookie，如下所示：
chain.filter(exchange).then(<a mono relevant to response>)
当我试图使用spock测试这个方法时，不会从存根Mono调用方法。
过滤器本身：
@Override
public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
return chain.filter(exchange)
.then(refreshCookie
浏览 3提问于2019-11-10得票数 0
回答已采纳
我正在使用rest运行一个无状态的spring引导应用程序，并希望禁用WebSessions的创建，如所描述的那样。
我已经创建了自己的不存储会话的WebSessionManager。
@Bean
public WebSessionManager webSessionManager() {
return new WebSessionManager() {
@Override
@NonNull
public Mono<WebSession> getSession(@NonNull final
浏览 4提问于2019-05-09得票数 7
回答已采纳
1回答
请考虑以下代码：
import reactor.core.publisher.Mono;
public class Main {
public static void main(String[] args) {
Mono.just(1)
.map(Main::return_int) // is ok
// .map(Main::return_void) // is not ok
.subscribe();
}
private static void return_void(int i
浏览 0提问于2019-07-10得票数 7
回答已采纳
2回答
我仍然是Spring Webflux的新手，Mono上的flatMap似乎不能工作。我有以下函数，但对kafkaPublisher.publishToTopic的调用不起作用。我插入print语句来测试它是否打印任何东西，但它甚至不执行print语句。publishToTopic返回Mono<Void>。
private Mono<Void> test(Long gId, UUID pId) {
Mono<UUID> nId = pDao.findNId(pId);
Mono<List<String>> channel
浏览 307提问于2018-11-30得票数 3
回答已采纳
我有两个Mono，要么返回一个404，要么生成一个result。
我如何将这两个Mono组合起来
一旦successfully.an完成，result就会被发出，一旦所有Mono产生404或面临任何其他错误，就会返回Mono Optional.empty？
我试过了
Mono<Result> mono0 = client.get()
.uri(uri1)
.retrieve()
.bodyToMono(Result.class)
.onErrorResume(e -> Mono.nev
浏览 4提问于2020-03-10得票数 1
回答已采纳
1回答
我目前正在尝试在OpenSUSE上安装Mono3.0.3。我已经从各自的tar ball编译并安装了每个部分(mono 3.0.3、XSP 2.10.1和Apache HTTPD 2.4.3)，但是mod_mono 2.10 (和2.8)都抛出了编译错误。
在编译和安装每个部分时，我已经确保所有前缀都是相同的：
./configure --prefix=/usr/local
make
make install
但是，make会导致mod_mono输出以下内容：
...SNIP...
mod_mono.c: In function ‘send_initial_data’:
mod_mono.c:
浏览 0提问于2013-01-10得票数 0
我正在使用StepVerifier测试值：
@Test
public void testStuff() {
Thing thing = new Thing();
Mono<Thing> result = Mono.just(thing);
StepVerifier.create(result).consumeNextWith(r -> {
assertEquals(thing, r);
}).verifyComplete();
}
我现在想做的是测试Mono中是否缺少项目。如下所示：
@Test
public void test
浏览 1提问于2018-07-19得票数 39
回答已采纳
我需要在IL代码中创建一个新的void方法，但是我不知道如何在字段中的语句"returnType as Mono.Cecil.TypeReference“中声明Void类型？下面的代码
Dim MethodAtt = Mono.Cecil.MethodAttributes.Public Or Mono.Cecil.MethodAttributes.HideBySig Or Mono.Cecil.MethodAttributes.SpecialName Or Mono.Cecil.MethodAttributes.RTSpecialName
Dim newm As New Method
浏览 1提问于2013-10-20得票数 2
回答已采纳
在基于WebFlux的Spring中，我有一个更复杂的用例，我在Mono的使用上遇到了一些小问题。长话短说，即使不需要，我的switchIfEmpty也会被调用。我准备了一个小例子，让我可以重现这个问题：
public class ReactiveTest {
@Test
void test1() {
isOdd(2)
.flatMap(this::onNotEmpty)
.switchIfEmpty(Mono.defer(this::onEmpty))
.block();
}
浏览 4提问于2022-01-12得票数 0
2回答
我寻找一种方法，正确地使用项目反应堆出版商，而不产生无用的GC压力，通过实例化整个管道在每次调用。
在我们的代码中，响应服务间HTTP请求的典型句柄函数如下所示：
final List<Function<ChangeEvent, Mono<Void>>> triggerOtherMicroservices;
@PostMapping("/handle")
public Mono<Void> handle(@RequestBody ChangeEvent changeEvent) {
return Mono
浏览 2提问于2020-06-05得票数 1
回答已采纳
这是一段代码
@Test
public void test_mono_void_mono_empty() {
Mono.just("DATA")
.flatMap(s -> Mono.just(s.concat("-")
.concat(s))
.doOnNext(System.out::println)
.then())
.switchIfEmpt
浏览 3提问于2019-12-05得票数 11
回答已采纳
2回答
如何模拟返回Mono<Void>的方法
我有一个返回Mono<Void>的方法
public Mono<Void> deleteMethod(Post post) {
return statusRepository.delete(post);
}
在我的测试类中，我想做这样的事情
given(statusRepository.delete(any(Post.class))).willReturn(Mono.empty());
有没有更好的方法来做到这一点？
有人能帮我吗？
谢谢。
浏览 114提问于2019-07-24得票数 13
回答已采纳
1回答
下面的代码在Visual中编译得很好，但是在Unity (4.6.x)中它会创建一个编译器错误：
public class ErrorTest
{
void DoSomething(bool a = true, bool f = true) { }
void DoSomething(int b, bool f = true) { }
public void SomeMethod()
{
DoSomething(f: false);
}
}
对DoSomething的调用使编译器窒息。问题是，为什么，真的没有歧义。
在Unity时，控
浏览 3提问于2015-07-06得票数 0
我有返回Mono<Boolean>的函数，并希望将其映射到Mono<Void> (因为这是我在控制器方法中返回的内容)。
有没有比返回.flatMap { Mono.empty<Void>() }更好的方法来返回这样的Mono
我无法使用.map{ null }，因为映射函数无法接受null%s。
浏览 57提问于2017-12-24得票数 27
回答已采纳
我有以下几点：
Flux<String> flux = ...
Mono<Void> mono = ...
Mono<Void> combined = operation(flux, mono);
它们代表并行发生的操作。
现在，我想将flux发出的所有元素输出到sysout，直到mono完成，这里使用的正确运算符是什么？
我试过了：
final Disposable subscribe = flux.subscribe(System.out::println);
mono.doOnSuccessOrError((o, e) -> subscrib
浏览 1提问于2019-06-11得票数 0
下面是使用Spring作为库由openapi-generator-maven-plugin生成的API的默认实现：
default Mono<ResponseEntity<Void>> testAPI(
@Parameter(hidden = true) final ServerWebExchange exchange
) {
Mono<Void> result = Mono.empty();
exchange.getResponse().setStatusCode(HttpStatus.NOT_IMPLEMENTED);
r
浏览 7提问于2022-05-31得票数 0
回答已采纳
这个有什么问题吗？
public static void test3() {
Mono<String> mono = Mono.just("");
System.out.println(mono);
for(int i=1; i<10; i++) {
mono = updateMono(mono, i);
System.out.println(mono);
}
mono.subscribe((s) -> System.out.println(s));
}
private static Mono<String
浏览 2提问于2021-04-23得票数 2
回答已采纳
我正在尝试使用Spring reactor webclient执行多个HTTP调用，该the客户端返回Mono。我使用Mono.block()等待所有monos完成。这并不是等到subscribe()完成。 public class UserValidator {
public Mono<User> getUserSummary(int userId) {
User user = new User();
// First Mono
Mono<Address> address = WebClientUtil.m
浏览 186提问于2021-08-10得票数 1
回答已采纳
"LinkAssemblies“任务意外失败。错误处理方法：“程序集中的Xamarin.Forms.Platform.Android.GestureManager::InitializeScaleDetector()‘：'Xamarin.Forms.Platform.Android.dll’-> Mono.Cecil.ResolutionException:解决System.Void System.Void失败( Mono.Linker.Steps.MarkStep.HandleUnresolvedMethod(MethodReference参考)在Mono.Linke
浏览 0提问于2019-03-04得票数 2
我用单调的方式将一些C#代码嵌入到iphone应用程序中。我能够调用C#代码并获得一个返回值，但我无法使用PInvoke从C#代码中调用C函数。我正试图让一个微不足道的例子发挥作用。这是一个简单的计算器。目标c代码调用C#代码来添加两个整数。然后，C#代码应该回调到objective代码中，并给出更新的值。下面是处理计算的C#代码：
public class MyClass
{
static public void Add(int a, int b)
{
updateResult(a + b);
}
[DllImport("
浏览 3提问于2011-02-22得票数 3
回答已采纳
您好，我正在使用NaCl的嵌入式Mono。到目前为止，一切都正常，但我不知道如何从c调用.NET方法，该方法不在执行.NET exe的同一线程上。
下面是我尝试使用的方法：
void Mono_InvokeMethod(const char* assemblyName, const char* method, const char* arg)
{
MonoAssemblyName* man = mono_assembly_name_new(assemblyName);
assert(man);
MonoAssembly* ma = mono_assembly_loade
浏览 11提问于2012-05-29得票数 1
回答已采纳
public interface RefreshTokenReactiveRepository extends ReactiveCrudRepository<RefreshToken, Long> {
Mono<RefreshToken> findByValue(String value);
}
下一个metod在TokenService类中。
public Mono<TokenPair> exchangeRefreshToken(String refreshTokenValue) {
return refreshTokenReactiveRepos
浏览 0提问于2018-06-11得票数 1
回答已采纳
1回答
我期望代码等待Mono完成，然后收集结果，但这从未发生过。 为什么？ 下面是我的代码： public static void main(String[] args) throws Exception {
Mono<Integer> mono1 = Mono.fromCallable(() -> 1);
Mono<Integer> mono2 = Mono.fromCallable(() -> 2);
List<Mono<Integer>> monos = Arrays.asList(m
浏览 52提问于2020-01-27得票数 2
根据下面的C#示例代码，从C中调用Bar.Work静态方法非常容易，所需做的就是获取一个MonoClass*，然后从类中获取一个MonoMethod*并调用它。
问题是，为了获得MonoClass*，我需要提供Bar的名称空间，在本例中是作为参数的函数的'sampleApp'。
MonoClass *klass = mono_class_from_name(image, "sampleApp", "Bar");
问题是，如果我不知道Bar的类命名空间，我如何在C中获得MonoClass*。有没有办法从C中获得程序集内的类型列表?我在mono的嵌入
浏览 2提问于2014-03-08得票数 1
1回答
我有各种各样的方法可以正常工作，但我只想在延迟之后才打电话给他们。为了避免为所有这些人编写不同的方法，我认为在某种程度上对Invoke更有好处。我创建了这些方法，以便它们排除Unity的timeScale，因此它们总是使用自定义构建的短函数等待Real seconds。
The WaitForRealSeconds
public class WaitForRealSecondsClass
{
#region Wait for real seconds
public Coroutine WaitForRealSeconds(float aTime, MonoBehaviour
浏览 5提问于2017-02-09得票数 1
回答已采纳
我试图将订阅服务器Context传递给在doOnNext中调用的fireAndForget方法。fireAndForget也运行异步非阻塞.如何传递此上下文，以使"key“的值存在？当我运行下面的测试时，它会通过。但是，在日志中我可以看到，对于这两个doOnNext，我得到了：
reactor.core.Exceptions$ErrorCallbackNotImplemented： java.util.NoSuchElementException:上下文为空
@Test
void shouldPassContextToFireAndForget() {
final Mono<
浏览 6提问于2021-10-13得票数 1
1回答
我正在处理以下用例的：
我执行一个返回Mono<Void>的请求
在此Mono成功后，我希望执行一个返回Mono<String>的可选操作。
为了决定何时执行第二个操作，我使用了filter，但它似乎不起作用
看起来是这样的：
Mono<Void> service = createService();
Mono<String> serviceKey = service.filter( x -> someBoolean)
.map( x -> someKey)
.flatMap(key -> {
浏览 0提问于2019-06-03得票数 0
回答已采纳
所以，我正在尝试使用Webflux，并且我有一个场景“检查一个对象是否存在；如果是，做一些事情，否则--指示错误”。
可在反应堆中写成：
public Mono<Void> handleObjectWithSomeId(Mono<IdType> id){
return id.
flatMap(repository::exists). //repository.exists returns Mono<Boolean>
flatMap(e -> e ? e : Mono.error(new DoesntExistEx
浏览 1提问于2018-04-07得票数 3
我有一个方法，它得到重定向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
回答已采纳
好吧，我完全被难住了--我也不能使用选择器从Mono调用Obj-C代码。因此，作为最后的尝试，我发布了以下代码：
@implementation MonoWrapper
- (id)init {
self = [super init];
if (self) {
NSBundle *main = [NSBundle mainBundle];
NSString *path = [main bundlePath];
const char *c_path = [path UTF8String];
[main autorelease];
[path auto
浏览 2提问于2011-03-30得票数 3
我正在尝试写一种方法来做这样的事情
Mono<A> ma = networkCall(); //this might fail
Mono<Void> mv = ma.map( a -> ....) #some logic to perform with `A`
return mv;
诀窍是，ma很可能会失败，然后我只想记录一下情况，并返回一个没有错误就完成的Mono<Void>。
看看Mono api，我刚刚找到了onErrorResume或onErrorReturn，但两者都会使用一个返回A的函数(这是我无法伪造的)，而我想返
浏览 1提问于2019-12-18得票数 2
回答已采纳
假设我有两个Monos，一个解析为Void/empty，另一个生成Integer，我如何并行执行这两个，并继续作为Mono<Integer>。具体地说，这两个Monos都是WebClient请求的结果。其中只有一个会产生有用的值，但这两个都需要成功才能继续。 例如： Mono<Void> a = sendSomeData();
Mono<Integer> b = getSomeNumber();
Mono<Integer> resultingStream = runConcurrentAndGetValue(a, b); 我该如何编写runC
浏览 65提问于2020-10-29得票数 1
回答已采纳
1回答
我正在尝试将mono嵌入到我正在编写的应用程序中，但是mono_field_set_value的行为并不像我认为的那样。下面是一个示例：
Montest.c：
#include <mono/jit/jit.h>
#include <mono/metadata/assembly.h>
#include <mono/metadata/debug-helpers.h>
#include <stdio.h>
#define TRUE 1
int main(){
MonoDomain *domain;
MonoAssem
浏览 0提问于2012-07-20得票数 3
回答已采纳
1回答
我在将一个对象发布到多个方法时遇到了问题。下面给出了我代码的简化版本。
package org.example.reactive;
import lombok.extern.slf4j.Slf4j;
import reactor.core.publisher.Mono;
import reactor.util.function.Tuple2;
import reactor.util.function.Tuple3;
@Slf4j
public class MonoTest {
public static void main(String... args) {
Mo
浏览 0提问于2020-04-24得票数 0
回答已采纳
1回答
我是春季网络流量的新手，我刚刚开始网络流量项目，我被困在一个地方。
我正在使用Id和FileName创建一个学生对象。
当我在deleteById(Long)方法上调用studentService时，首先要从存储中删除文件，然后从存储库中删除记录，
和所有这些方法都返回Mono
下面是我为学生提供服务和存储库的代码
public class Student {
private Long id;
private String fileName;
//getter & setter
}
public class StudentRepository {
publ
浏览 1提问于2019-12-25得票数 1
1回答
在处理定点DSP代码时，使用分析器时会产生一些困惑。
当我在以下代码上运行gprof时：
main()
{
...
g_apply( &g_mono, in_mono );
g_apply( &g_stereo, in_stereo );
...
}
I get (自身循环，子循环，函数名)：
16943.80, 4760.06 g_apply
但是我想看到单声道和立体声的不同循环，所以我这样做了：
void g_apply_mono(g* g_mono, in* in_mono)
{
g_apply( g_mono, in_m
浏览 22提问于2019-07-24得票数 0
我有下面的代码，它创建一个产品，然后在某种历史服务( journalClient)中记录创建-成功。
如果日志客户端出现错误，我想回滚产品创建。
@Service
public class ProductService {
public Mono<ProductRS> createProduct(final ProductRQ rq) {
return productclient.createProduct(rq).flatMap(produktfamilieRS -> {
return journalClient.createJou
浏览 2提问于2021-07-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
