constructor()

in lib/transcribe-service.js [116:133]


  constructor(pcmStream, access_id, secret_key) {
    super();
    const awsUrl = getSignedTranscribeWebsocketUrl(access_id, secret_key);
    const awsWsStream = websocket(awsUrl, {
      binaryType: "arraybuffer",
    });
    this.audioEventMessageTransformer = getAudioEventMessageTransformer();
    this.awsEventTransformerStream = getAwsEventTransformerStream();
    pcmStream
      .pipe(this.audioEventMessageTransformer)
      .pipe(awsWsStream)
      .pipe(this.awsEventTransformerStream);

    this.awsEventTransformerStream.on("data", (data) => {
      const transcription = data.toString("utf8");
      this.emit("transcription", transcription);
    });
  }