redis - Nestjs - 如何在 Nestjs e2e 测试中监听 ClientRedis 信号

Question

我正在尝试编写 e2e 测试，我正在使用 ClientRedis 类import { ClientRedis,} from '@nestjs/microservices';

在我的控制器中，我有一个监听和发送 redis 信号的函数

  @EventPattern(CREATE_BLOCK, Transport.REDIS)
  async blockCreated(block: Block) {
  await this.appService.parseBlock(block);
  this.logger.info({
  message: `parsed block: ${block.index}`,
  labels: { source: this.constructor.name },
});
this.client.emit(BLOCK_PARSED, block.index);

}

控制器中的客户端是 ClientRedis 的一个实例

@Inject(REDIS_INJECTION) private client: ClientRedis;

在我的 e2e 测试中，我试图收听PARSE_BLOCK从我的控制器发送的信号

我试过了ClientRedis_instance.createClient()，然后.on .subscribe .addListener 这些都不起作用