From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001 From: Pinapelz Date: Sat, 28 Jun 2025 17:26:46 -0700 Subject: initial commit: scaffolding --- node_modules/rxjs/src/internal/operators/max.ts | 54 +++++++++++++++++++++++++ 1 file changed, 54 insertions(+) create mode 100644 node_modules/rxjs/src/internal/operators/max.ts (limited to 'node_modules/rxjs/src/internal/operators/max.ts') diff --git a/node_modules/rxjs/src/internal/operators/max.ts b/node_modules/rxjs/src/internal/operators/max.ts new file mode 100644 index 0000000..8c2f5d0 --- /dev/null +++ b/node_modules/rxjs/src/internal/operators/max.ts @@ -0,0 +1,54 @@ +import { reduce } from './reduce'; +import { MonoTypeOperatorFunction } from '../types'; +import { isFunction } from '../util/isFunction'; + +/** + * The `max` operator operates on an Observable that emits numbers (or items that + * can be compared with a provided function), and when source Observable completes + * it emits a single item: the item with the largest value. + * + * ![](max.png) + * + * ## Examples + * + * Get the maximal value of a series of numbers + * + * ```ts + * import { of, max } from 'rxjs'; + * + * of(5, 4, 7, 2, 8) + * .pipe(max()) + * .subscribe(x => console.log(x)); + * + * // Outputs + * // 8 + * ``` + * + * Use a comparer function to get the maximal item + * + * ```ts + * import { of, max } from 'rxjs'; + * + * of( + * { age: 7, name: 'Foo' }, + * { age: 5, name: 'Bar' }, + * { age: 9, name: 'Beer' } + * ).pipe( + * max((a, b) => a.age < b.age ? -1 : 1) + * ) + * .subscribe(x => console.log(x.name)); + * + * // Outputs + * // 'Beer' + * ``` + * + * @see {@link min} + * + * @param comparer Optional comparer function that it will use instead of its + * default to compare the value of two items. + * @return A function that returns an Observable that emits item with the + * largest value. + */ +export function max(comparer?: (x: T, y: T) => number): MonoTypeOperatorFunction { + return reduce(isFunction(comparer) ? (x, y) => (comparer(x, y) > 0 ? x : y) : (x, y) => (x > y ? x : y)); +} -- cgit v1.2.3