### Question:
ReactorDemo implements ReactiveStreamsDemo { public static List<Integer> doSquares() { List<Integer> squares = new ArrayList<>(); Flux.range(1, 64) .onBackpressureBuffer(256).map(v -> v * v) .subscribeOn(Schedulers.immediate()) .subscribe(squares::add); return squares; }  static Flux<Long> exampleSquaresUsingGenerate(); static List<Integer> doSquares(); static List<Integer> doParallelSquares(); @Override Future<List<Integer>> doSquaresAsync(int count); @Override Future<String> doStringConcatAsync(int count); @Override Future<List<Integer>> doParallelSquaresAsync(int count); @Override Future<String> doParallelStringConcatAsync(int count); static void runComputation(); static void writeFile(File file); static void readFile(File file); static void useProcessor();  }### Answer:
@Test public void testDoSquares() { assertArrayEquals(squares.toArray(), demo.doSquares().toArray()); }