henrik · December 4, 2020 05:41 · henrik · Sep 18, 2015 · ghost · Oct 28, 2015
diff --git a/1-progressive_downloader.ex b/1-progressive_downloader.ex
 defmodule ProgressiveDownloader do
  def run do
    url = "https://ia600308.us.archive.org/2/items/HealthYo1953/HealthYo1953_512kb.mp4"

    HTTPotion.get url, stream_to: self, timeout: :infinity

    receive_data(total_bytes: :unknown, data: "")
  end

  defp receive_data(total_bytes: total_bytes, data: data) do
    receive do

      %HTTPotion.AsyncHeaders{headers: h} ->

        {total_bytes, _} = h[:"Content-Length"] |> Integer.parse
        IO.puts "Let's download #{mb total_bytes}…"
        receive_data(total_bytes: total_bytes, data: data)

      %HTTPotion.AsyncChunk{chunk: new_data} ->

        accumulated_data = data <> new_data
        accumulated_bytes = byte_size(accumulated_data)
        percent = accumulated_bytes / total_bytes * 100 |> Float.round(2)
        IO.puts "#{percent}% (#{mb accumulated_bytes})"
        receive_data(total_bytes: total_bytes, data: accumulated_data)

      %HTTPotion.AsyncEnd{} ->

        path = "/tmp/posture.mp4"
        File.write!(path, data)
        IO.puts "All downloaded! See: #{path}"

    end
  end

  defp mb(bytes) do
    number = bytes / 1_048_576 |> Float.round(2)
    "#{number} MB"
  end
 end
diff --git a/2-output.md b/2-output.md
	defmodule ProgressiveDownloader do
	def run do
	url = "https://ia600308.us.archive.org/2/items/HealthYo1953/HealthYo1953_512kb.mp4"

	HTTPotion.get url, stream_to: self, timeout: :infinity

	receive_data(total_bytes: :unknown, data: "")
	end

	defp receive_data(total_bytes: total_bytes, data: data) do
	receive do

	%HTTPotion.AsyncHeaders{headers: h} ->

	{total_bytes, _} = h[:"Content-Length"] \|> Integer.parse
	IO.puts "Let's download #{mb total_bytes}…"
	receive_data(total_bytes: total_bytes, data: data)

	%HTTPotion.AsyncChunk{chunk: new_data} ->

	accumulated_data = data <> new_data
	accumulated_bytes = byte_size(accumulated_data)
	percent = accumulated_bytes / total_bytes * 100 \|> Float.round(2)
	IO.puts "#{percent}% (#{mb accumulated_bytes})"
	receive_data(total_bytes: total_bytes, data: accumulated_data)

	%HTTPotion.AsyncEnd{} ->

	path = "/tmp/posture.mp4"
	File.write!(path, data)
	IO.puts "All downloaded! See: #{path}"

	end
	end

	defp mb(bytes) do
	number = bytes / 1_048_576 \|> Float.round(2)
	"#{number} MB"
	end
	end