Packages

ex_closeio

0.2.10
0.3.0 0.2.10 0.2.9 0.2.8 0.2.7 0.2.6 0.2.5 0.2.4 0.2.3 0.2.2 0.2.1 0.2.0 0.1.2 0.1.1 0.1.0 0.0.13 0.0.12 0.0.11 0.0.10 0.0.9 0.0.8 0.0.7 0.0.6 0.0.5 0.0.4 0.0.3 0.0.2 0.0.1

Close.io client library for Elixir.

HexDocs

Current section

Files

Jump to
Readme
28 Versions
2 Dependencies
Dependants
Files
Activity
ex_closeio lib ex_closeio result_stream.ex
Raw

lib/ex_closeio/result_stream.ex 

defmodule ExCloseio.ResultStream do

  @moduledoc ""



  def new(params, api_key, module) do

    Stream.resource(

      fn -> fetch_page(params, module, api_key) end,

      &process_page/1,

      fn _ -> :ok end

    )

  end



  defp fetch_page(params, module, api_key) do

    module.all(params, api_key)

    |> case do

      {:error, _} -> :error

      {:ok, %{"has_more" => has_more, "data" => items}} ->

        {items, params, has_more, module, api_key}

    end

  end



  defp process_page(:error),

    do: {:halt, nil}

  defp process_page({nil, _, false, _, _}),

    do: {:halt, nil}



  defp process_page({nil, params, _, module, api_key}) do

    params

    |> Map.update("_skip", 100, fn(val) -> val+100 end)

    |> Map.merge(%{"_limit" => 100})

    |> fetch_page(module, api_key)

    |> process_page

  end



  defp process_page({items, params, has_more, module, api_key}) do

    {items, {nil, params, has_more, module, api_key}}

  end

end