Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 8 additions & 1 deletion packages/voice/src/receive/AudioReceiveStream.ts
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,14 @@ export class AudioReceiveStream extends Readable {
this.renewEndTimeout(this.end);
}

return super.push(buffer);
const result = super.push(buffer);

if (buffer === null) {
// null marks EOF for stream
this.destroy();
}

return result;
}

private renewEndTimeout(end: EndBehavior & { duration: number }) {
Expand Down