com.oath.cyclops.internal.stream.spliterators.Zipping4Spliterator.()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-13 11:19:58 27 4

@Override
public <T2, T3, T4, R> ReactiveSeq<R> zip4(Iterable<? extends T2> second, Iterable<? extends T3> third, Iterable<? extends T4> fourth, Function4<? super T, ? super T2, ? super T3, ? super T4, ? extends R> fn) {
  return createSeq( new Zipping4Spliterator<>(get(),second.spliterator(),third.spliterator(),fourth.spliterator(),fn));
}

@Override
public Spliterator<R> copy() {
  return new Zipping4Spliterator(CopyableSpliterator.copy(left),
                  CopyableSpliterator.copy(middle),CopyableSpliterator.copy(middle2),
                  CopyableSpliterator.copy(right),fn);
}

public <R2> Zipping4Spliterator<T1,T2,T3,T4,R2> compose(Function<? super R,? extends R2> fn){
  return new Zipping4Spliterator<>(CopyableSpliterator.copy(left),CopyableSpliterator.copy(middle),CopyableSpliterator.copy(middle2),
      CopyableSpliterator.copy(right),
      this.fn.andThen4(fn));
}

@Override
public <T2, T3, T4, R> ReactiveSeq<R> zip4(Iterable<? extends T2> second, Iterable<? extends T3> third, Iterable<? extends T4> fourth, Function4<? super T, ? super T2, ? super T3, ? super T4, ? extends R> fn) {
  return createSeq( new Zipping4Spliterator<>(get(),second.spliterator(),third.spliterator(),fourth.spliterator(),fn));
}

@Override
public Spliterator<R> copy() {
  return new Zipping4Spliterator(CopyableSpliterator.copy(left),
                  CopyableSpliterator.copy(middle),CopyableSpliterator.copy(middle2),
                  CopyableSpliterator.copy(right),fn);
}

public <R2> Zipping4Spliterator<T1,T2,T3,T4,R2> compose(Function<? super R,? extends R2> fn){
  return new Zipping4Spliterator<>(CopyableSpliterator.copy(left),CopyableSpliterator.copy(middle),CopyableSpliterator.copy(middle2),
      CopyableSpliterator.copy(right),
      this.fn.andThen4(fn));
}

27 4 0

• java - EnumSet.spliterator 没有特征 Spliterator.NONNULL

  我在想问题的答案:How to test for null keys on any Java map implementation? 我的第一个想法是检查 map 键集的 Spliterator 是否

• interface - 接口(interface)中的 Java 8 : Spliterator, 迭代器、集合和 "default"实现(名为 spliterator 的重复方法)

  在 Java 1.8.0_25 发布到荒野之后有一个有趣的情况......我相信我的问题的根源主要与接口(interface)中“默认”实现的新(到 1.8)特性有关。 我正在开发的应用程序目前的目标

• Java Spliterator 不断拆分并行流

  我发现 Java 并行流有一些令人惊讶的行为。我自己制作了Spliterator ，并且生成的并行流被分割，直到每个流中只有一个元素。这似乎太小了，我想知道我做错了什么。我希望我可以设置一些特征来纠正

• java - 实现未知大小的非并行 Spliterator？

  我对我的所有研究感到有点困惑。我有一个名为 TabularResultSet 的自定义界面(为了举例，我已经淡化了它)它遍历任何本质上是表格的数据集。它有一个类似于迭代器的 next() 方法，它可以

• java - Spliterator 跳过部分文本

  我遇到了流的 dropWhile 或 takeWhile 方法的问题，因为 spliterator 正在跳过特定模式奇数或偶数中的文本部分。应该怎样处理文本的所有部分？我的方法在这里: void re

• java - Spliterator - 大小旗帜与小型旗帜

  https://docs.oracle.com/javase/8/docs/api/java/util/Spliterator.html SIZED Characteristic value sign

• java - 如何实现用于流式传输斐波那契数的 Spliterator？

  我正在玩 Java 8 Spliterator并创建了一个将斐波那契数字流式传输到给定的 n。所以对于斐波那契数列 0, 1, 1, 2, 3, 5, 8, ... n fib(n) -----

• java - 你能重新平衡一个未知大小的不平衡 Spliterator 吗？

  我想使用 Stream 并行处理一组未知数量的异构远程存储 JSON 文件(文件数量预先未知)。这些文件的大小差异很大，从每个文件 1 个 JSON 记录到某些其他文件中的 100,000 条记录。在

• java - 为什么用 Spliterators 创建的流没有被并行处理？

  这可能是非常基本的，但我不是 Java 人。这是我的处理代码，它只是打印和 hibernate : private static void myProcessings(int value)

• java-8 - Spliterator:线程安全与否？

  我正在查看 Spliterator 的文档，根据它，Spliterator 不是线程安全的: Despite their obvious utility in parallel algorithms,

• java - 并行流调用 Spliterator 的次数超过其限制

  我最近发现了一个错误 StreamSupport.intStream(/* a Spliterator.ofInt */, true) .limit(20) 调用 Spliterator.of

• java - Spliterator trySplit 返回类型

  我在 java.util.Spliterator (Java 8) 中偶然发现了一个有趣的细节。 方法 trySplit() 应该返回 Spliterator 的实例或 null，如果它不能被拆分。

• java - Spliterator 什么时候应该停止 split ？

  我明白 there is overhead in setting up并行 Stream 的处理，如果项目很少或每个项目的处理速度很快，则单线程中的处理速度更快。 但是，trySplit() 是否有类

• java - stream.spliterator() 是否关闭流？

  stream.spliterator() 是否隐式关闭了 stream，还是之后需要显式关闭它？ Stream stream = Stream.of("a", "b", "c"); Spliterat

• Java.util.Collection 重写 spliterator()

  在Collection的源代码中，我想知道为什么@Override使用注释。 spliterator()方法不是来自 Iterable ，和Object也没有。 public interface Co

• java - Spliterator 导致重复键异常，而 for 循环则不会

  我正在使用 Java 8 流。 当我使用 spliterator 添加到 map 时，出现重复键异常，但使用标准 for 循环不会引发异常。 // This works Map myMap = new

• java - Spliterator Java 8 - 自定义实现

  已结束。此问题正在寻求书籍、工具、软件库等的推荐。它不满足Stack Overflow guidelines 。目前不接受答案。 我们不允许提出寻求书籍、工具、软件库等推荐的问题。您可以编辑问题，以便

• java - Spliterator 与 Stream.Builder

  我读了一些关于如何创建有限的 Stream 的问题( Finite generated Stream in Java - how to create one? , How do streams sto

• java - 并行流的 Stream.spliterator 的奇怪行为

  我将流拆分器直接用于我正在编写的库中的低级操作。最近，当我进行流拆分器和交错 tryAdvance/trySplit 调用时，我发现了非常奇怪的行为。这是演示问题的简单代码: import java.

• java - Iterables.partition() 生成的 Spliterator 没有按预期运行？

  我注意到使用 Guava 的 Iterables.partition(collection, partitionSize).spliterator() 生成的拆分器表现得很奇怪。 在生成的拆分器上执行