NonRepeatingStream.java

NonRepeatingStream.java

import java.util.stream.*;
import java.util.concurrent.*;
import java.util.*;

public <T> Stream<T> nonRepeatingStream(List<T> src) {
  IntSupplier index = () -> ThreadLocalRandom.current().nextInt(0, src.size());
  return Stream.iterate(
     index.getAsInt(),
     (prev) -> {
         int next = index.getAsInt();
         while (prev == next) {
           next = index.getAsInt();
         }
         return next;
      }
   ).map(src::get);
}

Stream<String> stream = nonRepeatingStream(Arrays.asList("a", "b"));

stream.limit(10).forEach(el -> System.out.println(el));