-record(subscribe, {
    from :: gleam@erlang@process:subject({ok, integer()} | {error, binary()}),
    subscriber :: gleam@erlang@process:subject(glats:subscription_message()),
    subject :: binary(),
    queue_group :: gleam@option:option(binary())
}).