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);
});
}