[RxJava] Chap04

private fun executeInterval() {

    /*
    * 시작 시간을 표시하는 유틸리티 메소드이다.
    * RxJava - 비동기 프로그래밍이기 때문에 시간에 대한 이해가 중요하다.
    * 시작 시간을 기준으로 RxJava 각 함수의 실행 시간을 측정하기 위함이다.
    * sleep()을 호출하는 이유는 다른 스레드에서 실행이 완료될 때까지 기다려야 하기 때문이다.
    * 해당 문장을 주석 처리하게 되면 기다리지 않고 바로 프로그램이 종료되는 것을 확인할 수 있다.
    * 이유는 메인 스레드에서 할 일이 없기 때문이다.
    *
    * */

    CommonUtils.exampleStart()
    val source = Observable.interval(100L, TimeUnit.MILLISECONDS)
            .map { data ->
                (data + 1) * 100
            }
            .take(5)

    source.subscribe(Log::it)
    CommonUtils.sleep(TIME)
    CommonUtils.exampleComplete()
}
// 결과
RxComputationThreadPool-1 | 247 | value = 100
RxComputationThreadPool-1 | 347 | value = 200
RxComputationThreadPool-1 | 445 | value = 300
RxComputationThreadPool-1 | 545 | value = 400
RxComputationThreadPool-1 | 645 | value = 500
-----------------------

private fun executeTimer() {
    CommonUtils.exampleStart()
    val source = Observable.timer(500L, TimeUnit.MILLISECONDS)
            .map { notUsed ->
                SimpleDateFormat("yyyy/MM/dd HH:mm:ss")
                        .format(Date())
            }
    source.subscribe(Log::it)
    CommonUtils.sleep(1000)
    CommonUtils.exampleComplete()
    /*
    * timer() 함수도 메인 스케줄러가 아닌 계산 스케줄러에서 실행되기 때문에
    * 계산 스케줄러가 완료될 때까지 기다리기 위해서 sleep() 함수를 호출하여 준다.
    * 즉, 계산 스케줄러의 동작이 완료될 때까지 메인 스케줄러가 기다리는 것이다.
    * 그렇지 않으면 메인 스케줄러에서 할 일이 없기 때문에 프로그램이 바료 종료된다.
    * */
}
// 결과
RxComputationThreadPool-1 | 708 | value = 2019/06/03 21:26:26
-----------------------

/*
* range() 함수로 1부터 10까지 숫자를 생성한다.
* 그리고 filter() 함수를 이용해 짝수만 걸러낸다.
* 현재 쓰레드에서 실행된다.
* */
private fun executeRange() {
    Observable.range(1, 10)
            .filter { num ->
                num % 2 == 0
            }
            .subscribe(Log::i)
}
// 결과
main | value = 2
main | value = 4
main | value = 6
main | value = 8
main | value = 10

/*
* main 스레드에서 실행되는 것이 아니기 때문에 sleep() 함수를 호출한다.
* */
private fun executeIntervalRange() {
    Observable.intervalRange(1,
            5,
            100L,
            100L,
            TimeUnit.MILLISECONDS)
            .subscribe(Log::i)
    CommonUtils.sleep(1000)
}
// 결과
RxComputationThreadPool-1 | value = 1
RxComputationThreadPool-1 | value = 2
RxComputationThreadPool-1 | value = 3
RxComputationThreadPool-1 | value = 4
RxComputationThreadPool-1 | value = 5

private fun executeIntervalRangeUsingIntervalAndMapAndTake() {
    Observable.interval(100L, TimeUnit.MILLISECONDS)
            .map { data ->
                data + 1
            }
            .take(5)
            .subscribe(Log::i)
    CommonUtils.sleep(1000)
}

fun main(args: Array<String>){
    CommonUtils.exampleStart()
    val serverUrl: String = "https://api.github.com/zen"

    Observable.timer(2, TimeUnit.SECONDS)
            .map { it ->
                serverUrl
            }
            .map(OkHttpHelper::get)
            .repeat()
            .subscribe({
                Log.it("Ping result: $it")
            }, {
                Log.it("Ping result fail: ${it.message}")
            })
    CommonUtils.sleep(1000)
}

// 아래는 OkHttpHelper 클래스이다.
public class OkHttpHelper {
    private static OkHttpClient client = new OkHttpClient();
    public static String ERROR = "ERROR";

    public static String get(String url) throws IOException {
        Request request = new Request.Builder()
                .url(url)
                .build();
        try {
            Response res = client.newCall(request).execute();
            return res.body().string();
        } catch (IOException e) {
            Log.e(e.getMessage());
            throw e;
        }
    }

    public static String getT(String url) throws IOException {
        Request request = new Request.Builder()
                .url(url)
                .build();
        try {
            Response res = client.newCall(request).execute();
            return res.body().string();
        } catch (IOException e) {
            Log.et(e.getMessage());
            throw e;
        }
    }

    public static String getWithLog(String url) throws IOException {
        Log.d("OkHttp call URL = " + url);
        return get(url);
    }
}