Code snippet in Stream Paginated GraphQL API in Elixir medium blog post

stream_paginator.ex

defmodule MyApp.StreamPaginator do
  def stream(query, args \\ %{first: 100}) do
    init = fn -> request(query, args) end
    next = fn -> nil end
    stop = fn -> nil end

    Stream.resource(init, next, stop)
  end

  defp request(query, args) do
    query
    |> HttpClient.post(%{variables: args})
    |> case do
      {:ok,
       %{"data" => %{"records" => %{"edges" => edges, "pageInfo" => page}}}} ->
        {Enum.map(edges, & &1["node"]), page, query, args}

      {:error, _reason} ->
        {[], nil, query, args}
    end
  end
end