clicks$.pipe(
  tap(event => performSomeSideffect(event)),
).subscribe(
  event => allEvents$.next(event),
  error => allEvents$.error(error),
);