-record(subscribe, {
    reply_with :: gleam@erlang@process:subject({ok, nil} |
        {error, glubsub:glubsub_error()}),
    client :: gleam@erlang@process:subject(any())
}).