@Test void toFluxShouldReturnSameContent() { UnmodifiableIterator<String> iterator = ImmutableList.of("a", "b", "c").iterator(); Flux<String> actual = Iterators.toFlux(iterator); assertThat(actual.collect(toList()).block()).containsExactly("a", "b", "c"); }
public static <T> Flux<T> toFlux(Iterator<T> iterator) { return Flux.fromStream(toStream(iterator)); }
Iterators { public static <T> Flux<T> toFlux(Iterator<T> iterator) { return Flux.fromStream(toStream(iterator)); } }
Iterators { public static <T> Flux<T> toFlux(Iterator<T> iterator) { return Flux.fromStream(toStream(iterator)); }  }
Iterators { public static <T> Flux<T> toFlux(Iterator<T> iterator) { return Flux.fromStream(toStream(iterator)); }  static Stream<T> toStream(Iterator<T> iterator); static Flux<T> toFlux(Iterator<T> iterator); }
Iterators { public static <T> Flux<T> toFlux(Iterator<T> iterator) { return Flux.fromStream(toStream(iterator)); }  static Stream<T> toStream(Iterator<T> iterator); static Flux<T> toFlux(Iterator<T> iterator);  }