Pipes

Il n’y a pas de différence fondamentale entre les pipes réguliers et les pipes de microservices. La seule différence est qu’au lieu de lancer une HttpException, vous devez utiliser une RpcException.

Astuce

La classe RpcException est exposée par le paquet @nestjs/microservices.

Binding pipes

L’exemple suivant utilise un pipe avec une portée de méthode instanciée manuellement. Tout comme avec les applications basées sur HTTP, vous pouvez également utiliser des pipes avec une portée de contrôleur (c’est-à-dire, préfixer la classe du contrôleur avec un décorateur @UsePipes()).

Exemple d'utilisation des pipes

@UsePipes(new ValidationPipe())
@MessagePattern({ cmd: 'sum' })
accumulate(data: number[]): number {
  return (data || []).reduce((a, b) => a + b);
}

Exemple de pipe avec portée

@UsePipes(new ValidationPipe())
@MessagePattern({ cmd: 'sum' })
accumulate(data) {
  return (data || []).reduce((a, b) => a + b);
}