const destroy$ = new Subject();
source1$.pipe(
  takeUntil(destroy$)
)