从两个通量生成通量

Question

我现在正在使用Flux。我想创建一个通量

描述问题：我有一个工作案例，我有一个房屋清单和我所在的清单。我需要返回所有房屋的结果，我只会更改结果对象上的真/假标志。当然，第二个列表的元素可能更少。

有人能提出这样或其他的建议吗？

@RunWith(SpringRunner.class)
@SpringBootTest

public class WholesaleControllerTest {

@Test
public void testZipFlux() {
    Flux<Flux1> flux1 = Flux.just(new Flux1(1, "test1"), new Flux1(2, "test2"), new Flux1(3, "test3"));
    flux1.subscribe(item -> System.out.println("Flux1 " + item));
    Flux<Flux2> flux2 = Flux.just(new Flux2(2, true), new Flux2(1, false), new Flux2(3, true));
    flux2.subscribe(item -> System.out.println("Flux2 " + item));


    Flux<Result> = ...//TODO zip flux1 and flux2 to RESULT

}

@Getter
@Setter
@AllArgsConstructor
class Flux1{
    private int id;
    private String value;
}

@Getter
@Setter
@AllArgsConstructor
class Flux2{
    private int id_fk_flux2;
    private boolean value;
}


@Getter
@Setter
@AllArgsConstructor
class Result{
    private int id;
    private String flux1Value;
    private boolean flux2Value;
}

}

Answer 1

这是一种方法。但我不得不说，这不是严格意义上的反应式编程（因为我在第一个流量上使用块来创建映射）。

话虽如此，我想不出其他办法

Map<Integer, Flux1> flux1Map = flux1.collectMap(Flux1::getId, Function.identity()).block();

Flux<Result> results = flux2.flatMap(item -> {
        //TODO : Handle cases like key not found in flux1
        Flux1 entry = flux1Map.get(item.getId_fk_flux2());
        Result result = new Result(entry.getId(), entry.getValue(), item.isValue());
        return Mono.just(result);
    }).collectList().flatMapMany(Flux::fromIterable);