add empty optimisation for merge observable of observables with maxConcurrent