ObservableSequenceEqualExample.java 예제의 delay( ) 연산자 질문있습니다

안녕하세요,

해당 예제에서의 delay( ) 연산자를 첫 번째 유형(delay(Long delay, TimeUnit unit))으로 바꿔보았는데, 콘솔에 수행 결과 출력없이 종료됩니다.

public class ObservableSequenceEqualExample {
    public static void main(String[] args) {
        Observable<CarMaker> observable1 =
                Observable.fromArray(SampleData.carMakers)
                        .subscribeOn(Schedulers.computation())
                        .delay(300L, TimeUnit.MILLISECONDS)
                        .doOnNext(data -> Logger.log(LogType.DO_ON_NEXT, "# observable1 : " + data));

        Observable<CarMaker> observable2 =
                Observable.fromArray(SampleData.carMakers)
                        .delay(100L, TimeUnit.MILLISECONDS)
                        .doOnNext(data -> Logger.log(LogType.DO_ON_NEXT, "# observable2 : " + data));

        Observable.sequenceEqual(observable1, observable2)
                .subscribe(data -> Logger.log(LogType.ON_NEXT, data));
    }
}

Schedules.computation을 설정해서 그런가 싶어 주석 처리해보아도 결과는 동일했습니다.

어째서 두 유형의 delay( )이 결과 값이 다른지 모르겠습니다

* 추가 내용 (자문자답 아님!)

왜 이러한 차이점이 있는지 확인해본 바로는
첫 번째 유형의 delay는 아래와 같이 스케줄러를 통해 computation 스레드로 지정하는 것을 확인했습니다. 이 때문에 observable1, observable2가 각 스레드 computation로 실행되기 때문에 Thread.sleep( )을 주지 않는 이상 콘솔에 출력이 안되는 것 같습니다.

- Observable.java

@CheckReturnValue
@SchedulerSupport(SchedulerSupport.COMPUTATION)
public final Observable<T> delay(long delay, TimeUnit unit) {
    return delay(delay, unit, Schedulers.computation(), false);
}

반면 두 번째 유형의 delay 코드는 첫 번째 유형과 달리 실행할 스레드를 지정하는 코드가 없고 flatMap을 통해 데이터를 1개 씩 리턴하기 때문에 sequenceEqual( ) 연산자가 각각의 데이터를 비교할 수 있는 것이 아닐까 추측해봅니다...

@CheckReturnValue
@SchedulerSupport(SchedulerSupport.NONE)
public final <U> Observable<T> delay(final Function<? super T, ? extends ObservableSource<U>> itemDelay) {
    ObjectHelper.requireNonNull(itemDelay, "itemDelay is null");
    return flatMap(ObservableInternalHelper.itemDelay(itemDelay));
}

혹시 제가 추측한 내용 중에 틀린 부분이 있는지 확인부탁드립니다ㅜ

public class ObservableDelayExample02 {
    public static void main(String[] args) {
        Observable.just(1,3,5,7)
                .delay(item -> {
                    TimeUtil.sleep(1000L);
                    Logger.log(LogType.DO_ON_NEXT, item);
                    return Observable.just(item); // 새로운 Observable의 통지 시점에, 원본 데이터를 통지한다.
                }).subscribe(data -> Logger.log(LogType.ON_NEXT, data));
    }
}

doOnNext() | main | 20:20:38.076 | 1
onNext() | main | 20:20:38.148 | 1
doOnNext() | main | 20:20:39.148 | 3
onNext() | main | 20:20:39.148 | 3
doOnNext() | main | 20:20:40.159 | 5
onNext() | main | 20:20:40.159 | 5
doOnNext() | main | 20:20:41.160 | 7
onNext() | main | 20:20:41.160 | 7