@@ -0,0 +1,1099 @@
+package com.smp.rxplayround.sample.operator.aggregate;%0A%0Aimport com.smp.rxplayround.BasePlayground;%0A%0Aimport org.junit.Test;%0A%0Aimport lombok.extern.slf4j.Slf4j;%0Aimport rx.Observable;%0Aimport rx.Observer;%0Aimport rx.functions.Func2;%0A%0A/**%0A * Created by myungpyo.shim on 2016. 5. 25..%0A */%0A@Slf4j%0Apublic class Reduce extends BasePlayground %7B%0A%0A    @Test%0A    public void play() throws Exception %7B%0A%0A        Observable.from(new Integer%5B%5D%7B1, 2, 3, 4, 5, 6, 7, 8, 9, 10%7D).reduce(new Func2%3CInteger, Integer, Integer%3E() %7B%0A            @Override%0A            public Integer call(Integer integer, Integer integer2) %7B%0A                return integer + integer2;%0A            %7D%0A        %7D).subscribe(new Observer%3CInteger%3E() %7B%0A            @Override%0A            public void onCompleted() %7B%0A                log.debug(%22onCompleted%22);%0A            %7D%0A%0A            @Override%0A            public void onError(Throwable e) %7B%0A                log.debug(%22onError%22);%0A            %7D%0A%0A            @Override%0A            public void onNext(Integer integer) %7B%0A                log.debug(%22onNext : %7B%7D%22, integer);%0A            %7D%0A        %7D);%0A%0A    %7D%0A%7D%0A

Add reduce operator sample