Files
Kifi/kifi-api/test_flux.java

12 lines
335 B
Java

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