1. Operators
  2. Mathematical and Aggregate
  3. Min

Min

emits the item from the source Observable that had the minimum value

The Min operator operates on an Observable that emits numbers (or items that can be evaluated as numbers), and emits a single item: the item with the smallest number.

See Also

Language-Specific Information:

TBD

TBD

In RxGroovy, this operator is not in the ReactiveX core, but is part of the distinct rxjava-math module.

min

RxGroovy implements a min operator. It takes an optional comparator that it will use instead of its default to compare the value of two items. If more than one item has the identical minimum value, min will emit the last such item emitted by the source Observable.

minBy

The minBy operator is similar to min, but instead of emitting the item with the minimum value, it emits the item with the minimum key, where that key is generated based on a function you provide to minBy

In RxJava, this operator is not in the ReactiveX core, but is part of the distinct rxjava-math module.

min

RxJava implements a min operator. It takes an optional comparator that it will use instead of its default to compare the value of two items. If more than one item has the identical minimum value, min will emit the last such item emitted by the source Observable.

minBy

The minBy operator is similar to min, but instead of emitting the item with the minimum value, it emits the item with the minimum key, where that key is generated based on a function you provide to minBy

min

RxJS implements the min operator. It takes an optional comparer function that it will use instead of its default to compare the value of two items.

Sample Code

var source = Rx.Observable.fromArray([1,3,5,7,9,2,4,6,8]).min();

var subscription = source.subscribe(
  function (x) { console.log('Next: ' + x); },
  function (err) { console.log('Error: ' + err); },
  function () { console.log('Completed'); } );
Next: 1
Completed
minBy

The minBy operator is similar to min, but instead of emitting the item with the minimum value, it emits the item with the minimum key, where that key is generated based on a function you provide to minBy. minBy also takes an optional second parameter: a comparer function that it will use instead of its default to compare the keys of the two items.

minBy emits a list. If more than one item has the minimum key value, each such item will be represented in the list.

Sample Code

var source = Rx.Observable.fromArray([1,3,5,7,9,2,4,6,8,1])
               .minBy( 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: 1,1
Completed

min and minBy are found in the following distributions:

  • rx.all.js
  • rx.all.compat.js
  • rx.aggregates.js

They requires one of the following:

  • rx.js
  • rx.compat.js
  • rx.lite.js
  • rx.lite.compat.js

TBD

TBD

TBD

TBD

TBD