Fixing duplicated logic smell by attaching takeUntil() to the source Observable

fix-duplicated-logic.ts

import { from } from "rxjs";
import { filter, reduce } from "rxjs/operators";

const number$ = from([null, 2, 1, 0, 5, false, 6, 7]).pipe(
  filter<number>(Boolean)
);

// Adding numbers
number$
  .pipe(
    reduce((acc, curr) => acc + curr)
  )
  .subscribe(n => console.log(`Total: ${n}`));

// Emit even numbers
number$
  .pipe(
    filter(n => n % 2 === 0)
  )
  .subscribe(console.log);