如何将两个Flux对象组合成一个

Question

首先，我对反应式编程有点陌生。在参加了一些关于reactor和spring 5.0的演讲后，我想自己尝试一下这个编程模型。

我有一个应用程序，它使用WebClient从不同的API构建两个Flux对象。我想将这2个对象组合成一个并将其返回给用户。

代码示例如下所示：

public class User {
  private String username;
  //getters and setters
}

public class Address {
  private String street;
  //getters and setters;
}

public class CompleteUser {
  private String username;
  private String address;
  //getters and setters
}

现在在我的handler方法中：

final Flux<User> = WebClient.create()...;
final Flux<Address> = WebClient.create()...;
final Flux<CompleteUser> = //somehow compose this two types into one

我应该使用反应器API中的什么方法来实现这一点？我找到了一些方法来组合像组合最新的对象，但是在这种情况下，我想用第二个Flux的第一个项目等来完全组合第一个Flux的第一个项目。

Answer 1

Flux.zip静态方法正是您要寻找的。对于2个源的组合，您可以提供BiFunction来生成结果。

Flux<CompleteUser> complete = Flux.zip(fluxUser, fluxAddress, (u, a) -> new CompleteUser(u, a));
//if the ctor perfectly matches, you can also use CompleteUser::new