Project Reactor：有条件地实现映射输入Mono

Question

我正在尝试实现以下简单的命令式逻辑：

boolean saveImperative(final List list) {
    final String existingList = readByNameImperative(list.getName());
    if (Objects.isNull(existingList)) {
        templateSaveImperative(existingList);
        return true;
    } else {
        templateSaveImperative(existingList);
        return false;
    }
}

以声明的方式使用Project Reactor，这是我能够实现的：

@Test
public void testDeclarative() {
    final Mono<List> list = createList("foo");
    final Boolean result = save(list).block();
    System.out.println(result);
}

private Mono<Boolean> save(final Mono<List> listMono) {
    final Mono<List> existingListMono = listMono.cache()
            .flatMap(list -> readByName(list.getName()));
    // if
    final Mono<List> savedListMono = existingListMono
            .flatMap(existingList -> templateSave(Mono.just(existingList)));
    final Mono<Boolean> trueResult = savedListMono.map(x -> true);

    // else
    return trueResult.switchIfEmpty(templateSave(existingListMono).map(x -> false));
}

private Mono<List> templateSave(final Mono<List> listMono) {
    return listMono.map(list -> {
        System.out.println("templateSave has been called");
        return list;
    });
}

private Mono<List> readByName(final String listName) {
    if (listName != "list001") {
        return Mono.empty();
    }

    return createList(listName);
}

private Mono<List> createList(final String name) {
    final List list = List.builder().name(name).build();
    return Mono.just(list);
}

@Value
@Builder
private static class List {
    private final String name;
}

如果我用list001执行测试，它将打印：

templateSave has been called
true

正如预期的那样，但是如果我用foo进行调用，那么我得到

null

我会缺少什么？我期望输出如下：

templateSave has been called
false

在这种情况下。

Answer 1

final Mono<List> existingListMono = listMono.cache()
    .flatMap(list -> readByName(list.getName()));

...在您的保存方法中，将获取您现有的列表并使用readByName()对其进行平面映射。

您的readByName()方法如下：

private Mono<List> readByName(final String listName) {
    if (listName != "list001") {
        return Mono.empty();
    }

    return createList(listName);
}

（我不认为这与这个问题有关，但是don't use == or != for comparing strings。]

由于您的listName是foo，而不是list001，它返回一个空的Mono-因此existingListMono成为一个空的Mono，而savedListMono和trueResult也暗含。

但是，当您调用switchIfEmpty()语句时，您传入templateSave(existingListMono)-并且由于existingListMono如上所述是空的Mono，因此save()方法将返回空的Mono。

...并且当您阻止为空的Mono时，将得到null-因此结果为。