flatMap, concatMap 예제 코드에서 질문입니다.

작성한 질문수 4

1

안녕하세요? 업무 중이라서 답변이 조금 늦었네요.

윤정님께서 이해하고 계시는게 맞기도 한데 저한테 얘기하신 문장에서 조금 오해의 소지가 있는것 같아서 부연 설명을 잠깐 드리자면, interval 연산자의 파라미터인 period 값은 다운스트림(Downstream) 즉, interval 연산자의 아래쪽에 있는  take, skip, map 같은 연산자들이 interval 연산자가 통지한 데이터를 기다리기 위한 대기 시간이 아니라 interval 연산자가 통지하는 데이터의 통지 주기를 의미합니다.

period의 값을 '2'로 주면 interval 연산자 함수에서 2초에 한번씩 0부터 1씩 증가한 숫자를 통지하는 것이죠.

기다린다라는 말의 주체를 따진다면 interval 연산자 함수 자체가 해당 주기만큼 반복해서 기다리는 것이지 take, skip, map 같은 하위 연산자 함수가 기다리는건 아닌것이죠. ^^;

참고로 interval 함수에서 첫번째 통지되는 데이터를 대기없이 즉시 통지하고 싶다면 아래 소스처럼 initialValue 값을 '0'으로 주시면 된답니다.

public class ObservableIntervalExample {
    public static void main(String[] args){
        System.out.println("# start : " 
                + TimeUtil.getCurrentTimeFormatted());

        Observable.interval(0, 
                1000L, TimeUnit.MILLISECONDS)
                .map(num -> num + " count")
                .subscribe(data -> Logger.log(LogType.ON_NEXT, data));

        TimeUtil.sleep(3000);
    }
}

답변이 제대로 되셨는지 모르겠네요. 더 질문하실게 있으시면 언제든지 글 남겨주시면 감사드릴게요.