Minimal Elixir Concurrent Downloader

download.ex

defmodule Dl do
  def download(url) do
    case HTTPoison.get(url) do
      {:ok, response} ->
        case response.status_code do
          200 ->
            {response.body}
        end
      end
  end

  def bd do
    ["https://slashdot.org", "https://news.ycombinator.com"]
    |> Flow.from_enumerable
    |> Flow.map(&download/1)
    |> Flow.partition()
    |> Flow.map(fn {body} ->
      {:ok, file} = File.open("out_path", [:write])
      :ok = IO.binwrite(file, body)
      :ok = File.close(file)
    end)

    |> Flow.run
  end

end