pig

-module(pig@obs@consumer_spec).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/pig/obs/consumer_spec.gleam").
-export_type([consumer_spec/0]).

-if(?OTP_RELEASE >= 27).
-define(MODULEDOC(Str), -moduledoc(Str)).
-define(DOC(Str), -doc(Str)).
-else.
-define(MODULEDOC(Str), -compile([])).
-define(DOC(Str), -compile([])).
-endif.

?MODULEDOC(
    " Consumer specification for observability.\n"
    "\n"
    " A deferred consumer: a ChildSpec + the name to recover its Subject after start\n"
    " + a start function for the unsupervised path.\n"
).

-type consumer_spec() :: {consumer_spec,
        gleam@otp@supervision:child_specification(nil),
        gleam@erlang@process:name(pig@obs@events:session_event()),
        fun(() -> {ok,
                gleam@erlang@process:subject(pig@obs@events:session_event())} |
            {error, gleam@otp@actor:start_error()})}.