_.forEach(sourceStreams, (sourceStream, index) => {
        sourceStream
          .on('error', (error) => {
            logger.log('error', 'Error while obtaining data:', error)
            reject(error)