如何在不阻塞的情况下转换Mono对象？

Question

假设我有这个方法：

public static Mono<String> getData2() {
    return Mono.just("7");
}

我想调用这个方法，获取字符串，将该字符串转换为整数7，然后以非阻塞方式返回该整数。我该怎么做？

我试过这个，但是map函数阻塞（同步）：

public static Mono<Integer> getData1() {
    return getData2().map(data -> Integer.parseInt(data));
}

我尝试使用平面图代替（异步）：

public static Mono<Integer> getData1() {
    return getData2().flatMap(data -> Integer.parseInt(data));
}

但是我得到了这个错误：<代码>类型不匹配：无法从int转换为Mono

那我该怎么办？

Answer 1

在Spring反应器中，操作，如Mono。只需单声道。map等都是懒惰的求值。在订阅之前不会发生任何事情。阻塞通常发生在网络调用或资源锁定中。这是另一个概念。如果您想要一个异步的单声道。延迟可能会有所帮助。并且可以使用subscribeOn进行资源隔离。

回到问题，单声道。只是（“7”）。map（Integer：：parseInt）只提供一个mono对象。通过异步方式，我们可以将其更改为单声道。延迟（（）-