-module(fused@actor).
-compile([no_auto_import, nowarn_unused_vars, nowarn_unused_function, nowarn_nomatch, inline]).
-define(FILEPATH, "src/fused/actor.gleam").
-export([start/3]).

-file("src/fused/actor.gleam", 20).
-spec run(
    gleam@erlang@process:selector(FXP),
    gleam@erlang@process:pid_(),
    FXR,
    fun((gleam@erlang@process:pid_(), FXR, FXP) -> gleam@option:option(FXR))
) -> nil.
run(Selector, Self, State, Update) ->
    fused@promise:await(
        fused@process:selector_recv(Self, Selector),
        fun(Message) -> case Update(Self, State, Message) of
                {some, State@1} ->
                    run(Selector, Self, State@1, Update);

                none ->
                    fused@promise:resolve(nil)
            end end
    ).

-file("src/fused/actor.gleam", 5).
-spec start(
    gleam@erlang@process:pid_(),
    fun((gleam@erlang@process:pid_()) -> {FXJ,
        gleam@erlang@process:selector(FXK),
        FXM}),
    fun((gleam@erlang@process:pid_(), FXJ, FXK) -> gleam@option:option(FXJ))
) -> FXM.
start(Self, Init, Update) ->
    {Return_send, Return_recv} = fused@process:new(),
    begin
        fused@process:spawn(
            Self,
            fun(Self@1) ->
                {State, Selector, Return} = Init(Self@1),
                fused@process:send(Return_send, Return),
                run(Selector, Self@1, State, Update)
            end
        )
    end,
    fused@process:recv(Return_recv).