diff --git a/lib/httparrot/stream_handler.ex b/lib/httparrot/stream_handler.ex
new file mode 100644
index 0000000..d9b516f
--- /dev/null
+++ b/lib/httparrot/stream_handler.ex
@@ -0,0 +1,46 @@
+defmodule HTTParrot.StreamHandler do
+  @moduledoc """
+  Returns GET data.
+  """
+  alias HTTParrot.GeneralRequestInfo
+
+  def init(_transport, _req, _opts) do
+    {:upgrade, :protocol, :cowboy_rest}
+  end
+
+  def allowed_methods(req, state) do
+    {["GET"], req, state}
+  end
+
+  @doc """
+    `n` must be an integer between 1-100
+  """
+  def malformed_request(req, state) do
+    {n, req} = :cowboy_req.binding(:n, req)
+    try do
+      n = n |> binary_to_integer |> min(100) |> max(1)
+      {false, req, n}
+    rescue
+      ArgumentError -> {true, req, state}
+    end
+  end
+
+  def content_types_provided(req, state) do
+    {[{{"application", "json", []}, :get_json}], req, state}
+  end
+
+  def get_json(req, n) do
+    {info, req} = GeneralRequestInfo.retrieve(req)
+    {{:chunked, stream_response(n, info)}, req, nil}
+  end
+
+  defp stream_response(n, info) do
+    fn(send_func) ->
+      Enum.each 0..n-1, fn (i) ->
+        send_func.([id: i] ++ info |> JSEX.encode!)
+      end
+    end
+  end
+
+  def terminate(_, _, _), do: :ok
+end