def parse_reducer(data) do
    parse_reducer(data, &parse/1)

  def stream(data) do
    Stream.resource(
      fn -> {data, &parse/1} end,
      fn {data, parser} ->
        case parser.(data) do
          {:ok, {result, rest, next}} ->
            {[result], {rest, next}}
        end
      end,
      fn _ -> nil end
    )

  defp parse_reducer(<<>>, _parser) do
    :ok
  end
  defp parse_reducer(data, parser) do
    case parser.(data) do
      {:ok, {result, rest, next}} ->
        IO.inspect(result)
        parse_reducer(rest, next)
    end
  end