Function waitForText

test/unit-ci/session-transports.spec.js:159–191

(emitter, matcher, timeout = 5000)

}

function waitForText (emitter, matcher, timeout = 5000) {
  return new Promise((resolve, reject) => {
    let output = ''
    const timer = setTimeout(() => {
      cleanup()
      reject(new Error(`Timed out waiting for text. Received: ${output}`))
    }, timeout)

    const onData = (chunk) => {
      output += chunk.toString()
      if (matcher(output, chunk)) {
        cleanup()
        resolve(output)
      }
    }

    const onClose = () => {
      cleanup()
      reject(new Error(`Stream closed before matcher succeeded. Received: ${output}`))
    }

    const cleanup = () => {
      clearTimeout(timer)
      emitter.off('data', onData)
      emitter.off('close', onClose)
      emitter.off('end', onClose)
    }

    emitter.on('data', onData)
    emitter.on('close', onClose)
    emitter.on('end', onClose)
  })
}

describe('session-ftp transport flows', () => {
  let ftpServer