public class test_flux2 {
    public static void main(String[] args) {
        try {
            reactor.core.publisher.Flux.fromIterable(null).subscribe();
            System.out.println("Did not throw");
        } catch(Exception e) {
            System.out.println("Threw: " + e.getClass().getName());
        }
    }
}