blob: 7e7d17cb372cdd08d68d6e17078a84c76cc9f085 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
import { identity } from '../util/identity';
import { operate } from '../util/lift';
import { createOperatorSubscriber } from './OperatorSubscriber';
export function distinctUntilChanged(comparator, keySelector = identity) {
comparator = comparator !== null && comparator !== void 0 ? comparator : defaultCompare;
return operate((source, subscriber) => {
let previousKey;
let first = true;
source.subscribe(createOperatorSubscriber(subscriber, (value) => {
const currentKey = keySelector(value);
if (first || !comparator(previousKey, currentKey)) {
first = false;
previousKey = currentKey;
subscriber.next(value);
}
}));
});
}
function defaultCompare(a, b) {
return a === b;
}
//# sourceMappingURL=distinctUntilChanged.js.map
|
