current

defmodule Current do
  @moduledoc ~S"""
  """

  @type method :: :cursor | :keyset

  @type option :: {:method, method}
  @type options :: [option]

  defmacro __using__(_) do
    quote location: :keep do
      defoverridable stream: 1, stream: 2

      @spec stream(queryable :: Ecto.Queryable.t(), options :: Current.options()) :: Enum.t()
      @doc ~S"""
      """
      def stream(queryable, options \\ []) do
        case Keyword.pop(options, :method, :cursor) do
          {:cursor, options} ->
            super(queryable, options)

          {:keyset, options} ->
            Current.Stream.__build__(__MODULE__, queryable, options)
        end
      end
    end
  end
end