Spring被动-重用单值

Question

我使用flatMap进行了一系列Mono转换。我设法将我的生产代码简化为这个测试用例：

@Test
public void test() {
    AtomicInteger iCounter = new AtomicInteger(1);
    Mono<String> iValueMono = Mono.fromSupplier(() -> {
        int iValue = iCounter.getAndIncrement();
        System.out.println("iValueMono CALL: " + iValue);
        return String.valueOf(iValue);
    });

    Mono<String> resultMono = Mono.just("X")
            .flatMap(append(iValueMono))
            .flatMap(append(iValueMono));

    StepVerifier.create(resultMono)
            .consumeNextWith(result -> assertThat(result).isEqualTo("X11"))
            .expectComplete()
            .verify();
}

private Function<String, Mono<String>> append(Mono<String> sMono) {
    return s -> sMono.map(v -> s + v);
}

这张照片是：

iValueMono CALL: 1
iValueMono CALL: 2

org.junit.ComparisonFailure: 
Expected :"X11"
Actual   :"X12"

我想——我现在知道这是不正确的——每次我在append（）调用中映射iValueMono，供应商都会被重新执行以产生一个新的值。我无法在生产代码中更改iValueMono的实现方式（例如，使其有状态地存储值）。我如何实现这一点，以便只调用一次值供应商，并得到最终结果“X11”？

当然，我对一种非阻塞、反应式的方法感兴趣。

Answer 1

我重写了你的测试，现在iValueMono只执行一次，看起来：

@Test
public void test() {
    AtomicInteger iCounter = new AtomicInteger(0);
    Mono<String> iValueMono = getMono(iCounter.incrementAndGet());

    Mono<String> resultMono = Mono.just("X")
        .flatMap(append(iValueMono))
        .flatMap(append(iValueMono));

    StepVerifier.create(resultMono)
        .consumeNextWith(result -> assertEquals(result, "X11"))
        .expectComplete()
        .verify();
}

private Mono<String> getMono(int x) {
    System.out.println("Called");
    return Mono.just(String.valueOf(x));
}

你觉得怎么样？有帮助吗？

Answer 2

使用Mono。cache（）就是答案：

将此单声道转换为热源，并缓存最后发出的信号供进一步的订阅者使用。

使用它：

Mono<String> iValueMono = Mono.fromSupplier(() -> {
    int iValue = iCounter.getAndIncrement();
    System.out.println("iValueMono CALL: " + iValue);
    return String.valueOf(iValue);
}).cache();

只需给供应商打一次电话，即可达到预期效果。