split flux into 2

gistfile1.txt

public static void main(String[] args) {
        Flux<Integer> integerFlux = Flux.fromIterable(List.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10));

        Flux<Integer> cache = integerFlux
            .doOnNext(i -> System.out.println("on next " + i))
            .publish()
            .refCount(2);
        Flux<Integer> even = cache.filter(i -> i % 2 == 0);
        Flux<Integer> odd = cache.filter(i -> i % 2 != 0);
        even.subscribe(i -> System.out.println("on next even " + i), System.err::println, () -> System.out.println("complete even"));
        odd.subscribe(i -> System.out.println("on next odd " + i), System.err::println, () -> System.out.println("complete odd"));
    }