你可以flux.zip一个mono和一个flux并对每个flux值重复mono值吗？

Question

有可能做类似下面代码的事情吗？我有一个服务进行API调用，另一个返回值流。我需要用API调用返回的值修改每个值。

return Flux.zip(
                     someMono.get(),
                     someFlux.Get(),
                     (d, t) -> {
                         //HERE D IS ALWAYS THE SAME AND T IS EVERY NEW FLUX VALUE
                     });

我尝试过用。repeat（）处理单声道，它可以工作，但是每次有新的流量值时它都会调用方法，而且是API调用，所以不好。

有可能吗？

Answer 1

您可以使用cache运算符来完成此操作。取消对flux的注释而不使用cache，您将看到对getnum==100的调用数。使用缓存时，它将是1。

public class RepeatableMono {

  private static AtomicInteger numberOfCalls = new AtomicInteger(0);

  static Integer getNum() {
    System.out.println("GetNum Called: " + numberOfCalls.incrementAndGet());
    return 0;
  }

  public static void main(String[] args) {
    // This will print `GetNum Called: ` 100 times.
    //Flux<Integer> neverEndingFlux = Mono.defer(() -> Mono.just(getNum()))
    // .repeat();

    // This will print `GetNum Called: ` 1 times.
    Flux<Integer> neverEndingFlux = Mono.defer(() -> Mono.just(getNum()))
        .cache()
        .repeat();

    Flux<Integer> stream = Flux.range(1, 100);

    Flux.zip(neverEndingFlux, stream, (x, y) -> x + " " + y)
        .subscribe(System.out::println);
  }
}