RxJS Example 05

rxjs-example-05.ts

import {from} from 'rxjs/internal/observable/from';
import {distinctUntilChanged} from 'rxjs/operators';

const source = [
  {x: 1, y: 1},
  {x: 1, y: 2},
  {x: 3, y: 5},
  {x: 6, y: 9},
  {x: 2, y: 1},
  {x: 3, y: 5},
  {x: 8, y: 5},
  {x: 2, y: 3},
  {x: 1, y: 2},
  {x: 9, y: 7},
];
const sequence$ = from(source);
const distance = 2.5;
sequence$
  .pipe(
    distinctUntilChanged((prev, next) => {
      return Math.sqrt((prev.x - next.x)**2 + (prev.y - next.y)**2) < distance
    })
  )
  .subscribe((val) => {
    console.log(val)
  });