package dev.elaine.springlab.reactive;

import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;

import java.util.List;

public final class ReactorSample {
    private ReactorSample() {}

    public static List<Integer> transform() {
        return Flux.range(1, 5)
                .map(number -> number * number)
                .publishOn(Schedulers.parallel())
                .filter(square -> square % 2 == 1)
                .collectList()
                .block();
    }
}