diff --git a/packages/nestjs-batch-queue/src/batch-queue/producer.ts b/packages/nestjs-batch-queue/src/batch-queue/producer.ts index d72e9d49..f63eaff7 100644 --- a/packages/nestjs-batch-queue/src/batch-queue/producer.ts +++ b/packages/nestjs-batch-queue/src/batch-queue/producer.ts @@ -4,6 +4,9 @@ import type { QueueName } from './types/index.js' export class Producer { constructor(private batchQueue: BatchQueue) {} + /** + * Delegates to {@link BatchQueue.add} + */ async produce(queueName: QueueName, data: T): Promise { await this.batchQueue.add({ queueName, item: data }) }