-record(manager_state, {
    eventsourcing_actor :: gleam@option:option(gleam@erlang@process:subject(eventsourcing:aggregate_message(any(), any(), any(), any()))),
    expected_queries :: integer(),
    registered_queries :: integer(),
    eventstore :: eventsourcing:event_store(any(), any(), any(), any(), any(), any()),
    handle :: fun((any(), any()) -> {ok, list(any())} | {error, any()}),
    apply :: fun((any(), any()) -> any()),
    empty_state :: any()
}).