@Test public void flattenWithLeadingInfiniteStream_runInParallel() throws Exception {

  Stream<Integer> flattened =
      MoreStreams.flatten(Stream.of(Stream.iterate(1, i -> i + 1), Stream.of(100)));
  assertThat(flattened.parallel().limit(1000).collect(toList()))
      .hasSize(1000);
}