一、描述

发射原始Observable的最大值。

Max操作符操作一个发射数值的Observable并发射单个值：最大的那个值。

RxJava中，max属于rxjava-math模块。

max接受一个可选参数，用于比较两项数据的大小，如果最大值的数据超过一项，max会发射原始Observable最近发射的那一项。

maxBy类似于max，但是它发射的不是最大值，而是发射Key最大的项，Key由你指定的一个函数生成。

二、示意图

max

三、示例代码

由于max操作符是属于可选的rxjava-math模块的，所以需要加入下面的依赖：

1	compile 'io.reactivex:rxjava-math:1.0.0'

MathObservable.max(Observable.just(10, 6, 23, 9))
    .subscribe(new Subscriber<Integer>() {
        @Override
        public void onCompleted() {
            System.out.println("onCompleted.");
        }

        @Override
        public void onError(Throwable e) {
            System.out.println("onError: " + e.getMessage());
        }

        @Override
        public void onNext(Integer integer) {
            System.out.println("onNext: " + integer);
        }
    });