_.forEach(targetStreams, (targetStream, index) => {
        targetStream
          .on('error', (error) => {
            logger.log('error', 'Error while submitting data:', error)
            reject(error)