@Test void toFluxShouldReturnEmptyStreamWhenEmptyIterator() { UnmodifiableIterator<String> emptyIterator = ImmutableList.<String>of().iterator(); Flux<String> actual = Iterators.toFlux(emptyIterator); assertThat(actual.count().block()).isEqualTo(0); }
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);  }