tap()

Esse operador do rxjs manipula a stream de dados do Observable, a cada chamada do metódo next, acessa o valor do retorno podendo o visualizar os dados, é ideal para visualização de cada operação realizada na pipe.

Exemplo

O Exemplo abaixo manipula o Observable do tipo UserEntity, exibindo cada propriedade na execução do tap.

import { tap, Observable } from 'rxjs';

interface UserEntity {
  id: number;
  name: string;
}

const userEntityObservable: Observable<UserEntity> = new Observable<UserEntity>(
  (subscribe) => {
    const userEntity: UserEntity = {
      id: 1,
      name: 'Joana',
    };

    subscribe.next(userEntity);
    subscribe.complete();
  },
);

const tapUserEntity: Observable<UserEntity> = userEntityObservable.pipe(
  tap((userEntity: UserEntity) => {
    console.log(userEntity.id);
    console.log(userEntity.name);
    /*
      // 1
      // 'Joana'
    */
  }),
);

function executeTapUserEntity() {
  tapUserEntity.subscribe((user) => {
    console.log(user);
    /*
     {
      id: 1,
      name: 'Joana',
    };
    */
  });
}

export { executeTapUserEntity };

Para visualizar a implementação desse fluxo acessar:

codesandbox

Exemplo com nest-js

No projeto está implementado no operador personalizado de logs que é utilizado nas camadas: Repository, Application e Interface.

git - Operador para tratar logs

Docs

rxjs learn rxjs