Current section

Files

Jump to
x3m_system lib gen_aggregate_mod.ex
Raw

lib/gen_aggregate_mod.ex

defmodule X3m.System.GenAggregateMod do
@callback apply_event_stream(pid, function) :: :ok
@callback handle_msg(pid, atom, X3m.System.Message.t(), Keyword.t()) ::
{:ok, X3m.System.Message.t(), any} | any
@callback commit(pid, String.t(), X3m.System.Message.t(), integer) ::
{:ok, X3m.System.Aggregate.State.t()} | :transaction_timeout
end