someStream$.pipe(
  map(({a1, a2}: {a1: number, a2: string}) => {
     this.doSomething(a1, a2);
     return {a1, a2};
  })
);