使用JDK8和lambda（java.util.stream.streams.zip）压缩流

Question

在带有lambda b93的JDK8中，b93中有一个类java.util.Stream.streams.zip，可以用来压缩流（这在Dhananjay Nene编写的Exploring Java8 lambda.Part 1教程中进行了说明）。此功能：

然而，在b98中，这种情况消失了。事实上，B98中的java.util.Stream甚至不能访问Streams类。

这个功能已经移动了吗？如果移动了，我如何使用B98简洁地压缩流？

我想到的应用程序是Shen的这个java实现，在这里我替换了

null

具有相当冗长代码的函数（没有使用b98中的功能）。

Answer 1

我也需要这个，所以我只是从b93中获取源代码，并将其放入一个“util”类中。我不得不稍微修改它以使用当前的API。

下面是工作代码供参考（风险自负……):

public static<A, B, C> Stream<C> zip(Stream<? extends A> a,
                                     Stream<? extends B> b,
                                     BiFunction<? super A, ? super B, ? extends C> zipper) {
    Objects.requireNonNull(zipper);
    Spliterator<? extends A> aSpliterator = Objects.requireNonNull(a).spliterator();
    Spliterator<? extends B> bSpliterator = Objects.requireNonNull(b).spliterator();

    // Zipping looses DISTINCT and SORTED characteristics
    int characteristics = aSpliterator.characteristics() & bSpliterator.characteristics() &
            ~(Spliterator.DISTINCT | Spliterator.SORTED);

    long zipSize = ((characteristics & Spliterator.SIZED) != 0)
            ? Math.min(aSpliterator.getExactSizeIfKnown(), bSpliterator.getExactSizeIfKnown())
            : -1;

    Iterator<A> aIterator = Spliterators.iterator(aSpliterator);
    Iterator<B> bIterator = Spliterators.iterator(bSpliterator);
    Iterator<C> cIterator = new Iterator<C>() {
        @Override
        public boolean hasNext() {
            return aIterator.hasNext() && bIterator.hasNext();
        }

        @Override
        public C next() {
            return zipper.apply(aIterator.next(), bIterator.next());
        }
    };

    Spliterator<C> split = Spliterators.spliterator(cIterator, zipSize, characteristics);
    return (a.isParallel() || b.isParallel())
           ? StreamSupport.stream(split, true)
           : StreamSupport.stream(split, false);
}