comparing two different collections on common attribute reactively.

Lipu-example

  @Test
  public void testComparingTwoDifferentReactiveCollectionsOnMatchingAttribte() {

    final Mono<List<RecordA>> recordAMonoList = Mono.just(
        List.of(new RecordA("1"), new RecordA("2")));
    final Mono<List<RecordB>> recordBMonoList = Mono.just(
        List.of(new RecordB("1", "Record 1"), new RecordB("2", "Record 2")));

    recordAMonoList.zipWith(recordBMonoList).map(this::compareAndFilterLists).subscribe(
        System.out::println, System.err::println, () -> System.out.println("Done")
    );
  }

  private List<RecordA> compareAndFilterLists(Tuple2<List<RecordA>, List<RecordB>> tuple) {
//    Comparator<IdProvider> idProviderComparator = Comparator.comparing(IdProvider::id);
    return tuple.getT1()
        .stream()
        .filter(r -> tuple.getT2().stream().anyMatch(b -> b.id().equals(r.id())))
        .collect(
            Collectors.toList());
  }