RxJava flatMap运算符的歧义行为

Question

public class MainActivity1 extends AppCompatActivity {
    private String LOG_TAG = "MY_LOG";
    private CompositeDisposable compositeDisposable = new CompositeDisposable();

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        compositeDisposable.add(getObservable().subscribeWith(getObserver()));
    }

    private Observable<Integer> getObservable(){
        return Observable.just(1,2,3).flatMap(lValue -> Observable.just(lValue,lValue,lValue));
    }

    private DisposableObserver<Integer> getObserver(){
        return new DisposableObserver<Integer>() {
            @Override
            public void onNext(@NonNull Integer s) {
                Log.d(LOG_TAG,"onNext : " + s);
            }

            @Override
            public void onError(@NonNull Throwable e) {
                Log.d(LOG_TAG,"onError");
            }

            @Override
            public void onComplete() {
                Log.d(LOG_TAG,"onComplete");
            }
        };
    }
}

以上代码的输出为：

D/MY_LOG: onNext : 1
D/MY_LOG: onNext : 1
D/MY_LOG: onNext : 2
D/MY_LOG: onNext : 2
D/MY_LOG: onNext : 3
D/MY_LOG: onNext : 3
D/MY_LOG: onComplete

这里1、2和3每次打印两次。由于在just运算符内的flatMap运算符内传递了三个值，因此，预期的行为应该是每次打印1、2和3三次。有谁知道为什么会观察到这种奇怪的行为？

Answer 1

代码似乎很好。有时可能与日志有关，如果您经常打印，则日志可能不会打印所有值。尝试添加doOnNext，然后查看just是否发出所有值

 Observable.just(lValue,lValue,lValue).doOnNext(new Consumer<Integer>() {
        @Override
        public void accept(Integer integer) throws Throwable {
            Log.d(TAG, "accept: "+ integer);
            // or use debugger to check the value
        }
    })