How to get Stream to run?

Hi there,

I’ve got the following function to read from a CSV file and insert the data into the address table of my database.

  def process_csv_file(%User{type: "customer"} = customer, file) do
    File.stream!(file)
    |> Stream.map(& &1)
    |> CSV.decode(separator: ?;, headers: false)
    |> Stream.map(fn x ->
      case x do
        {:ok, [name, address, zip_code, city, country]} ->
          create_address(customer, %{
            name: name,
            address_one: address,
            zip_code: zip_code,
            city: city,
            country: country
          })

        _ ->
          IO.puts("Something went wrong...")
      end
    end)
    |> Stream.run()
  end

If I try to run it, it returns :ok and nothing happens.

But if I use Enum instead of Stream, everything runs fine. What am I doing wrong here?

(In this case it isn’t very important, it’s just a small file. But I’m hoping to learn something from this.)