Method waitForOutput

test/test-utils/cli.ts:72–98

(expected: string, source: Source, caller: Parameters<typeof Error.captureStackTrace>[1])

  }

  private waitForOutput(expected: string, source: Source, caller: Parameters<typeof Error.captureStackTrace>[1]) {
    const error = new Error('Timeout')
    Error.captureStackTrace(error, caller)

    return new Promise<void>((resolve, reject) => {
      if (this[source].includes(expected)) {
        return resolve()
      }

      const timeout = setTimeout(() => {
        error.message = `Timeout when waiting for error "${expected}".\nReceived:\nstdout: ${this.stdout}\nstderr: ${this.stderr}`
        reject(error)
      }, process.env.CI ? 20_000 : 4_000)

      const listener = () => {
        if (this[source].includes(expected)) {
          if (timeout) {
            clearTimeout(timeout)
          }

          resolve()
        }
      }

      this[`${source}Listeners`].push(listener)
    })
  }
}

function isWritable(stream: any): stream is Writable {