Java 8流API缺乏获取流元素索引的功能，也缺乏将流压缩在一起的功能。这是不幸的，因为它使某些应用程序(如LINQ挑战)比其他应用程序更难。

然而，经常会有变通办法。通常，这可以通过使用整数范围“驱动”流来实现，并利用原始元素通常位于一个数组或一个可以通过索引访问的集合中这一事实。例如，挑战2的问题可以这样解决:

String[] names = {"Sam", "Pamela", "Dave", "Pascal", "Erik"};

List<String> nameList =
    IntStream.range(0, names.length)
        .filter(i -> names[i].length() <= i)
        .mapToObj(i -> names[i])
        .collect(toList());

如上所述，这利用了数据源(名称数组)是直接可索引的这一事实。否则，这项技术就行不通。

我承认这并不能满足挑战2的目的。尽管如此，它还是相当有效地解决了这个问题。

EDIT

我前面的代码示例使用flatMap来融合过滤器和映射操作，但这很麻烦，而且没有任何好处。我已经根据Holger的评论更新了示例。

除了protonpack之外，jOOλ的Seq也提供了这种功能(通过在其上构建的扩展库，如cyclops-react，我是这个库的作者)。

Seq.seq(Stream.of(names)).zipWithIndex()
                         .filter( namesWithIndex -> namesWithIndex.v1.length() <= namesWithIndex.v2 + 1)
                         .toList();

Seq还只支持Seq.of(names)，并将在幕后构建一个JDK流。

简单反应的等效物看起来类似

 LazyFutureStream.of(names)
                 .zipWithIndex()
                 .filter( namesWithIndex -> namesWithIndex.v1.length() <= namesWithIndex.v2 + 1)
                 .toList();

简单反应版本更适合异步/并发处理。

如果列表是唯一的，我们可以使用indexOf方法。

List<String> names = Arrays.asList("Sam", "Pamela", "Dave", "Pascal", "Erik");

    names.forEach(name ->{
        System.out.println((names.indexOf(name) + 1) + ": " + name);
    });

没有一种方法可以在访问索引的同时遍历流，因为流不同于任何集合。Stream只是一个将数据从一个地方传输到另一个地方的管道，如文档中所述:

没有存储。流不是存储元素的数据结构;相反，它们通过计算操作管道携带来自源(可以是数据结构、生成器、IO通道等)的值。

当然，正如您在问题中暗示的那样，您总是可以将Stream<V>转换为Collection<V>，例如List<V>，在其中您将可以访问索引。

最简洁的方法是从一系列指数开始:

String[] names = {"Sam", "Pamela", "Dave", "Pascal", "Erik"};
IntStream.range(0, names.length)
         .filter(i -> names[i].length() <= i)
         .mapToObj(i -> names[i])
         .collect(Collectors.toList());

结果列表只包含“Erik”。

当你习惯for循环时，另一种看起来更熟悉的方法是使用可变对象维护一个临时计数器，例如AtomicInteger:

String[] names = {"Sam", "Pamela", "Dave", "Pascal", "Erik"};
AtomicInteger index = new AtomicInteger();
List<String> list = Arrays.stream(names)
                          .filter(n -> n.length() <= index.incrementAndGet())
                          .collect(Collectors.toList());

注意，在并行流上使用后一种方法可能会中断，因为项目不一定会“按顺序”处理。

为了完整起见，这里是涉及我的StreamEx库的解决方案:

String[] names = {"Sam","Pamela", "Dave", "Pascal", "Erik"};
EntryStream.of(names)
    .filterKeyValue((idx, str) -> str.length() <= idx+1)
    .values().toList();

这里我们创建了一个EntryStream<Integer, String>，它扩展了Stream<Entry<Integer, String>>，并添加了一些特定的操作，如filterKeyValue或values。也使用了toList()快捷方式。