如何通过将两个Flux中的值配对成一个Tuple来组合发布者？

Question

假设我有如下两个通量:

    Flux<Integer> f1 = Flux.just(10,20,30,40);
    Flux<Integer> f2 = Flux.just(100,200,300,400);

现在我想把这些通量组合成一个通量或者两个通量的元组，在一个通量中包含两个通量元素。

我使用zipwith方法尝试了以下操作：

  Flux<Integer, Integer> zipped = f1.zipWith(f2,
                                            (one, two) ->  one + "," +two)
                                    .subscribe();

但是这给出了一个编译时错误:

 Incorrect number of arguments for type Flux<T>; it cannot be parameterized with arguments <Integer, Integer>

我怎样才能做到这一点？请建议。

Answer 1

Flux只有一个类型参数，所以< code>Flux

因此，从本质上讲，您将两个整数映射到一个字符串，因此压缩的类型应该是Flux。

或者，您可以映射到自己创建的特殊元组类（或者从您正在使用的库中）：

public class Pair<A,B> {
    private final A first;

    private final B second;

    public Pair(A first, B second) {
        this.first = first;
        this.second = second;
    }

    public A getFirst() {
        return first;
    }

    public B getSecond() {
        return second;
    }
}

然后，您可以按如下方式映射它：

Flux<Integer> f1 = Flux.just(10,20,30,40);
Flux<Integer> f2 = Flux.just(100,200,300,400);

Flux<Pair<Integer,Integer>> result = f1.zipWith(f2,
    (one, two) ->  new Pair<>(one, two));

或者更短：

Flux<Pair<Integer,Integer>> result = f1.zipWith(f2, Pair::new);