-record(subscription, {
    pubsub :: glyn@pubsub:pub_sub(any()),
    group :: any(),
    subject :: gleam@erlang@process:subject(any()),
    subscriber_pid :: gleam@erlang@process:pid_()
}).