如何从MONO/FLUX中提取字符串值-

Question

我是Reactor编程新手，需要MONO/Flux方面的帮助

我有POJO课程

受雇者Java语言

class Employee {
   String name
}

我在访问服务时返回了Mono，我需要从Mono中提取名称作为字符串。

Mono<Employee> m = m.map(value -> value.getName()) 

但这再次返回Mono而不是字符串。我需要从这个Mono中提取String值。

Answer 1

您应该避免阻塞（），因为它将无限期地阻塞，直到收到下一个信号。

您不应该认为反应容器将为您的程序提供答案。相反，你需要对这个答案做任何你想做的事情。例如：

employeeMono.subscribe(value -> whatYouWantToDoWithName(value.getName()));

Answer 2

您应该这样做：

m.block().getName();

此解决方案不考虑空检查。

标准方法是：

Employee e = m.block();
if (null != e) {
   e.getName();
}

但使用flux时，应继续使用以下内容：

Mono.just(new Employee().setName("Kill"))
    .switchIfEmpty(Mono.defer(() -> Mono.just(new Employee("Bill"))))
    .block()
    .getName();

请记住，如果可能，应该避免请求阻塞操作：它会阻塞流