stopAndStart.ts

restartStream() {
    if (this.recognizeStream) {
      this.recognizeStream.end();
      this.recognizeStream.removeAllListeners();
      this.recognizeStream = null;
    }
    if (this.resultEndTime > 0) {
      this.finalRequestEndTime = this.isFinalEndTime;
    }
    this.resultEndTime = 0;

    this.lastAudioInput = [];
    this.lastAudioInput = this.audioInput;

    this.restartCounter++;

    if (!this.lastTranscriptWasFinal) {
      process.stdout.write("\n");
    }
    process.stdout.write(
      chalk.yellow(
        `${this.streamingLimit * this.restartCounter}: RESTARTING REQUEST\n`
      )
    );

    this.newStream = true;

    this.startRecognitionStream();
  }

  /**
   * Closes the recognize stream and wipes it
   */
  stopRecognitionStream() {
    if (this.recognizeStream) {
      this.recognizeStream.end();
			this.recognizeStream.removeAllListeners();
    }
    if (this.restartTimeout) {
      clearTimeout(this.restartTimeout);
    }
    this.recognizeStream = null;
  }