RxJava

[Java]

RxJava

FeliZ_하늘.. 2016. 2. 23. 14:28

maven dependency 추가

테스트 클래스

import org.junit.Test;
import rx.Observable;
import rx.Subscriber;
import rx.functions.Action1;
import rx.observables.MathObservable;

/**
 * description.
 *
 * @author Ha Neul, Kim
 * @since 0.1
 */
public class RxJavaTest {

@Test
    public void helloTest() {
        Observable<Integer> numbers = Observable.range(1, 4);
        numbers.subscribe(new Action1<Integer>() {
            @Override
            public void call(Integer integer) {
                System.out.println("------------------ RxJavaTest.call.integer = " + integer);
            }
        });

Observable<Integer> sum = MathObservable.sumInteger(numbers);
        Observable<Integer> max = MathObservable.max(numbers);

PrintSubscriber maxSubscriber = new PrintSubscriber();
        max.subscribe(maxSubscriber);
        System.out.println("------------------ RxJavaTest.helloTest.maxSubscriber.getPrintValue() = " + maxSubscriber.getPrintValue());
        PrintSubscriber sumSubscriber = new PrintSubscriber();
        sum.subscribe(sumSubscriber);
        System.out.println("------------------ RxJavaTest.helloTest.sumSubscriber.getPrintValue() = " + sumSubscriber.getPrintValue());
    }

private class PrintSubscriber extends Subscriber<Integer> {

private int printValue;

@Override
        public void onCompleted() {
        }

@Override
        public void onError(Throwable e) {
        }

@Override
        public void onNext(Integer integer) {
            this.printValue = integer;
        }

public int getPrintValue() {
            return printValue;
        }
    }
}

결과

저작자표시 변경금지 (새창열림)