refactor(merge): make MergeProducer code shorter
refactor(merge): make MergeProducer code shorter

staltz/xstream,andersonleite/xstream,staltz/xstream,staltz/xstream,andersonleite/xstream,andersonleite/xstream,staltz/xstream