mesketh

  public record RecordA(String id) { }
  public record RecordB(String id, String name) { }
  @Test
  public void testFilteringRecordAListWithIdsNotFoundOnRecordBList() {

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

mesketh

  public record RecordA(String id) { }
  public record RecordB(String id, String name) { }
  @Test
  public void testComparingTwoDifferentReactiveCollectionsOnMatchingAttribte() {

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

mesketh

  @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")

mesketh

/*
 * Copyright 2008-present MongoDB, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *   http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software

mesketh

<?xml version="1.0" encoding="UTF-8"?>
<code_scheme name="GoogleStyle">
  <option name="OTHER_INDENT_OPTIONS">
    <value>
      <option name="INDENT_SIZE" value="2" />
      <option name="CONTINUATION_INDENT_SIZE" value="4" />
      <option name="TAB_SIZE" value="2" />
      <option name="USE_TAB_CHARACTER" value="false" />
      <option name="SMART_TABS" value="false" />
      <option name="LABEL_INDENT_SIZE" value="0" />

mesketh

package org.eclipse.jkube.maven.sample.spring.boot;

import io.prometheus.client.CollectorRegistry;
import io.prometheus.client.Histogram;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Lazy;

@Configuration

mesketh

        String usernamePrefix =
                box.getEnv().getUsername().toUpperCase().replaceAll("[^a-zA-Z0-9]", StringUtil.EMPTY_STRING);