@Test void shouldActuallyRunThings() { AtomicBoolean sideEffect = new AtomicBoolean(false); Runnables.runParallel(() -> sideEffect.set(true)); assertThat(sideEffect).isTrue(); }
public static void runParallel(Runnable... runnables) { Flux<Runnable> stream = Flux.just(runnables); runParallel(stream); }
Runnables { public static void runParallel(Runnable... runnables) { Flux<Runnable> stream = Flux.just(runnables); runParallel(stream); } }
Runnables { public static void runParallel(Runnable... runnables) { Flux<Runnable> stream = Flux.just(runnables); runParallel(stream); }  }
Runnables { public static void runParallel(Runnable... runnables) { Flux<Runnable> stream = Flux.just(runnables); runParallel(stream); }  static void runParallel(Runnable... runnables); static void runParallel(Flux<Runnable> runnables); }
Runnables { public static void runParallel(Runnable... runnables) { Flux<Runnable> stream = Flux.just(runnables); runParallel(stream); }  static void runParallel(Runnable... runnables); static void runParallel(Flux<Runnable> runnables);  }