Flow Example

flow_example.ex

defmodule Sandbox do
  def hello do
    [1, 3, 5, 7]
    |> Flow.from_enumerable()
    |> Flow.map(&get(&1))
    |> Flow.map(&process(&1))
    |> Flow.reduce(fn -> [] end, fn value, acc -> [value | acc] end)
    |> Enum.to_list
    |> IO.inspect

    :world
  end

  def get(id) do
    %{id: id}
  end

  def process(payload) do
    Map.merge(payload, %{ value: :rand.uniform(100) })
  end
end

output.md

➜  sandbox mix test
[
  %{id: 7, value: 49},
  %{id: 5, value: 81},
  %{id: 3, value: 5},
  %{id: 1, value: 73}
]
.

Finished in 0.03 seconds
1 test, 0 failures

Randomized with seed 963740