如果不是空的，spring rector会抛出异常

Question

与Spring Reactor类似：当publisher发出值时，如何引发异常？

我在DAOjava findSomePojo中有一个finder方法，它返回结果SomePojo。finder调用amazon db API和Java软件。亚马逊。awssdk。服务。dynamodb。模型GetItemResponse具有调用的输出。所以我在我的服务层createSomePojo方法中尝试这个hasElement（）检查。（不确定我是否正确使用了它-我正在尝试和调试）

基本上：我想检查是否已经存在元素，保存是非法的，我不会调用DAOs save。所以我需要抛出异常。

假设在DB中已经有了某个Pojo的记录，我尝试调用服务create_SomePjo。但是我在日志中看到过滤器不工作，当Reactor调用时得到NPEcreateModel_SomePojo让我相信，即使在检查过滤器之后，它也会抛出NPE

///service SomePjoService it has create_SomePojo, find_SomePojo etc

Mono<Void>  create_SomePojo(reqPojo){

// Before calling DAO 's save I call serivice find (which basically calls DAOs find (Shown befow after this methid)
       Mono<Boolean> monoPresent = find_SomePojo(accountId, contentIdExtn)
                 .filter(i -> i.getId() != null)
                 .hasElement();
       System.out.println("monoPresent="+monoPresent.toString());
       if(monoPresent.toString().equals("MonoHasElement")){
       //*************it comes here i see that***********//
           System.out.println("hrereee monoPresent="+monoPresent);
          // Mono<Error> monoCheck=
                return  monoPresent.handle((next, sink) -> sink.error(new SomeException(ITEM_ALREADY_EXISTS))).then();
       } else {
           return SomePojoRepo.save(reqPojo).then();
       }

}

Mono<SomePojo> find_SomePojo(id){
    return SomePojoRepo.find(id);
}

==============================================================

///DAO : SomePojoRepo.java : it has save,find,delete
Mono<SomePojo> find( String id) {
    Mono<SomePojo> fallback = Mono.empty();
    Mono<GetItemResponse> monoFilteredResponse = monoFuture
        .filter(getItemResponse -> getItemResponse.item().size() > 0&& getItemResponse!=null);
    Mono<SomePojo> result = monoFilteredResponse
        .html" target="_blank">map(getItemResponse -> createModel_SomePojo(getItemResponse.item()));

    Mono<SomePojo> deferedResult = Mono.defer(() -> result.switchIfEmpty(fallback));
        return deferedResult;
}

我看到Mono上有hasElement（）方法。不知道如何正确使用它。如果我在我的服务中直接调用DAO save create_SomePojo（reqPojo），而不进行所有findner检查，我就可以实现异常，因为主键约束会处理并抛出exception，而我cna rethrow，然后在服务中捕获，但如果我想在服务中检查并抛出带有错误代码的异常，该怎么办。这样做的目的不是将响应错误对象传递给dao层。

Answer 1

尝试使用钩子。onOperatorDebug（）hook以获得更好的调试体验。

正确使用hasElement（假设find_SomePojo从不返回null）

Mono<Boolean> monoPresent =  find_SomePojo(accountId, contentIdExtn)
        .filter(i -> i.getId() != null)
        .hasElement();

return monoPresent.flatMap(isPresent -> {
    if(isPresent){
        Mono.error(new SomeException(ITEM_ALREADY_EXISTS)));
    }else{
        SomePojoRepo.save(reqPojo);
    }
}).then();

旁注

对于单声道实际上是什么，有一种常见的误解。它不保存任何数据——它只是管道的一部分，通过管道传输信号和数据。因此，行系统。出来println（“monpresent=”monpresent.toString（））毫无意义，因为它只是在现有管道周围打印hasElements（）装饰器。此装饰器的内部名称为MonoHasElement，无论其中包含什么（true/false），都会打印出MonoHasElement）。

打印信号（以及与之一起传输的数据）的正确方法是：Mono.log（），Mono.doOnAll/Next（System.out::println）或System.out.println（单呈现=单Present.block ()); .小心第三个：它会阻塞整个线程，直到数据被发出，所以只有当你知道你在做什么时才使用它。

使用Monos打印的示例：

   Mono<String> abc = Mono.just("abc").delayElement(Duration.ofSeconds(99999999));

    System.out.println(abc); //this will print MonoDelayElement instantly
    System.out.println(abc.block()); //this will print 'abc', if you are patient enough ;^)
    abc.subscribe(System.out::println); //this will also print 'abc' after 99999999 seconds, but without blocking current thread