This is RxJS v 4. Find the latest version here
Returns the maximum value in an observable sequence according to the specified comparer.
keySelector
(Function
): Key selector function.[comparer]
(Function
): Comparer used to compare elements.
(Observable
): An observable sequence containing a list of zero or more elements that have a maximum key value.
/* Without comparer */
var source = Rx.Observable.from([1,3,5,7,9,2,4,6,8,9])
.maxBy(function (x) { return x; });
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
// => Next: 9,9
// => Completed
File:
Dist:
Prerequisites:
NPM Packages:
NuGet Packages:
Unit Tests: