}
/**
- * @param {String} name
- * @param {(channel, message) => Promise<void>} messageHandler
- * @param {Object} options
- * @param {Integer=} prefetch
+ * @param {string} name name
+ * @param {(channel: string, message: any) => Promise<void>} messageHandler message handler
+ * @param {object} options options
+ * @param {number=} prefetch prefetch
*/
async consume(name, messageHandler, options, prefetch = this.options.prefetch) {
const _scope = _fileScope('consume');