Javascript 流库 - 实现

Question

java 流（或其他语言的任何其他函数库）非常好。

例如，您可以拥有 (js sudo code)。

Stream.of([1, 2, 3]).filter(x => x > 2).map(x => x * 5).result(); // [15]

忽略语法或具体实现，这只是一个例子。

现在我的问题是流程有点复杂。

例如，如果我需要像这样的每个步骤的不同数据：

Stream.of([1,2, 3])
  .map(x => x * 3)
  .zip([4, 5, 6])
  .map(..//here i need the initial array)
  .map(..//here i need the zipped array)
  .total(..//

正如您所见，在某些方法中我需要最后计算的值，在某些方法中我需要初始值。

此外，在某些情况下，我需要中间值，但在计算它们之后。

map(x => x * 1).map(x => x * 2).map(x => x * 4).map(..//i need the result from 2nd map (x*2)

这是一个愚蠢的例子，但说明了问题。

这个问题有没有好的解决办法。

我认为我可以将所有数据保存在对象中，但这会导致代码更加冗长，因为在每一步我都必须设置并从对象中获取属性。

另一个例子： 对数字求和：[1, 2, 3, 4] -> 10 2以上的过滤器号：[1, 2, 3, 4] -> [3, 4] 将每个数字与总和相乘：[30, 40]

  Stream.of([1,2,3, 4])
    .sum()
    .filter(// here will be the sum, but i want the initial array and later the sum)
    .map(// here i want the filtered array and the calculated sum)

谢谢

Answer 1

如果需要中间结果，则保存计算：

const initial = Stream.of([1,2,3,4]);
const total   = initial.sum();
const result  = initial.filter(x => x > 2).map(x => x * total);

上面的示例是编写此类代码的最合乎逻辑的方式。我不明白你为什么要写这样的代码：

Stream.of([1,2,3, 4])
    .sum()
    .filter(/* here will be the sum, but i want the initial array and later the sum */)
    .map(/* here i want the filtered array and the calculated sum */)

您的示例令人困惑和误导。无需链接以函数式编写的代码。

Answer 2

我不了解所有语言——我主要是一名 Java 开发人员——但据我了解，不，没有像您正在搜索的那样的灵丹妙药。

在这些类型的库中使用的 Stream 的比喻总是这样的

[input stream] --{read elements one by one}--> [calculate] --> [output stream]

不要将[input stream] 视为集合的视图（尽管在 99% 中它是这样使用的）。更一般地考虑它，例如，一个网络套接字，您可以从中一个一个地读取元素。在你读完一个元素后，它就从网络套接字中消失了，你不能倒带。

所以，基本原理就是

• 每个元素只读取一次，
• 所有[calculate] 进程都可能并行运行，并且
• [calculate] 进程没有副作用

此原则允许库在内部优化和并行化您的计算，这是 Stream API 的主要目标。

所以，回答您的问题：如果您需要多次访问流元素的计算，则需要将原始流或中间结果保存在集合中。