Simplified read-side projection without limit or reverse support.

Behaves like Counterpoint.OnDemandProjection but always reads the full event stream in chronological order. Use OnDemandProjection when you need Query.limit/2 or Query.reverse/1; use this one for straightforward full-stream folds.

use Counterpoint.Projection injects @behaviour Counterpoint.Projection.

Example

defmodule MyApp.Views.TotalRevenue do
  use Counterpoint.Projection
  alias Counterpoint.Query
  alias MyApp.Events.OrderPlaced

  @impl Counterpoint.Projection
  def query(_args),
    do: Query.new() |> Query.add_item(types: [OrderPlaced])

  @impl Counterpoint.Projection
  def init, do: 0

  @impl Counterpoint.Projection
  def apply(total, %Counterpoint.Envelope{data: %OrderPlaced{total: t}}),
    do: total + t
end

Counterpoint.Projection.run(MyApp.Views.TotalRevenue, :my_store)