-record(pull_subscription, {
    conn :: gleam@erlang@process:subject(glats:connection_message()),
    sid :: integer(),
    stream :: binary(),
    consumer :: binary(),
    inbox :: binary()
}).