使用Stream后是否需要调用Enum，Stream.map/2返回值重复如何处理

问题原因及解决方法 #

重复输出的常见排查路径

• 检查源流实现
  你当前的流是通过Stream.resource/3构造的，先单独消费这个原始源流（不挂载后续的map逻辑），如果单个元素已经重复，说明Stream.resource/3的next回调实现有问题：确保每次回调仅返回{[单个元素], 新状态}或者:done，不要单次返回多个元素，也不要重复返回同一元素。
• 检查流处理链配置
  确认你没有误用Stream.flat_map/2替代Stream.map/2：flat_map会把处理函数返回的列表自动展开为多个独立元素，也会导致输出重复。
• 检查是否多次消费同一个Stream实例
  Stream是惰性无状态结构，每一次遍历都会从头执行完整的流处理逻辑。如果你提前对同一个Stream做了打印、校验类的遍历操作，后续再次遍历收集时相当于重新跑了一次完整逻辑，很容易出现重复。
  解决方法：在流处理链末尾添加Stream.memoize/1缓存处理结果，后续多次消费也只会执行一次处理逻辑，不会重复生成元素：

  processed_stream = 
    原始源流
    |> Stream.map(你的处理函数)
    |> Stream.memoize()
  

• 兜底去重方案
  如果暂时无法定位根因，可以在流处理链中加Stream.uniq/1直接过滤重复元素：

  processed_stream = 
    原始源流
    |> Stream.map(你的处理函数)
    |> Stream.uniq()
  

不使用Enum相关函数生成列表的方法

如果你的场景是仅中间处理阶段不能使用Enum的立即求值函数，最终收集阶段可以直接用Enum.to_list/1把Stream转为列表，这个操作不会影响中间的惰性处理逻辑。
如果你确实完全不能使用任何Enum相关函数，可以手动实现递归遍历收集逻辑：

defmodule StreamConverter do
  def to_list(stream, acc \\ []) do
    case Enumerable.next(stream, %{}) do
      {:done, _} -> reverse_list(acc)
      {:suspended, element, continuation} ->
        to_list(continuation.({:cont, []}), [element | acc])
    end
  end

  defp reverse_list([], acc), do: acc
  defp reverse_list([head | tail], acc), do: reverse_list(tail, [head | acc])
end

# 调用示例
result_list = StreamConverter.to_list(processed_stream)

内容的提问来源于stack exchange，提问作者user17139608