¿Por qué no estoy recibiendo actualizaciones de mi suscripción?

Estoy tratando de configurar las Subscriptions de GraphQL, pero parece que se conecta al backend pero no envía ninguna actualización.

En el frontend, estoy utilizando Nuxt 2 y así es como estoy intentando hacerlo funcionar:

Esta es mi consulta de prueba

export const pendingInquiresSubscription = () => {
    return gql`
        subscription PendingInquires {
            countPendingInquires {
                amount
            }
        }`
}

Mi smartQuery en el componente de página

apollo: {
    $subscribe: {
        pendingInquires: {
            query: pendingInquiresSubscription(),
            result({ data, loading }) {
                this.loading = loading;
                console.log(data)
            },
            error(err) {
                this.$notify({ message: `Something went wrong while trying to update the count of new inquiries: ${err.message}`, type: 'error' })
            },
        }
    }
},

Backend:

Mi pubsub

import { RedisPubSub } from 'graphql-redis-subscriptions';
import Redis from 'ioredis';

const REDIS_DOMAIN_NAME = '127.0.0.1'
const PORT_NUMBER = 6379

const options = {
    host: REDIS_DOMAIN_NAME,
    port: PORT_NUMBER,
    retryStrategy: (times: any) => {
        return Math.min(times * 50, 2000);
    }
}

export const pubsub = new RedisPubSub({
    publisher: new Redis(options),
    subscriber: new Redis(options)
})

Mi esquema

extend type Subscription {
  countPendingInquires: PendingInquires!
}

type PendingInquires {
    amount: Int!
}

Mi resolver

...
    Subscription: {
        countPendingInquires: {
            subscribe: () => pubsub.asyncIterator(['countPendingInquires'])
        },
    },
...

Así es como estoy intentando enviar el evento:

pubsub.publish('countPendingInquires', {
    PendingInquires: {
        amount: await TelegramInguireModel.find({ }).countDocuments()
    }
})

También me pregunto si hay alguna forma incorporada de establecer el estado inicial para las suscripciones.