import { from } from'rxjs';import { distinctUntilChanged } from'rxjs/operators';constsampleObject= { name:'Test' };// Objects must be same referenceconstsource$=from([sampleObject, sampleObject, sampleObject]);// only emit distinct objects, based on last emitted valuesource$.pipe(distinctUntilChanged()).subscribe(console.log);// output: {name: 'Test'}