Class ObservableConcatMapEager.ConcatMapEagerMainObserver<T,​R>