public-mirrors/Kokoro-FastAPI
1
0
Fork 0
mirror of https://github.com/remsky/Kokoro-FastAPI.git synced 2025-04-13 09:39:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Repair the error 'Error: Error generating speech: Failed to execute 'endOfStream' on 'MediaSource': The 'updating' attribute is true on one or more of this MediaSource's SourceBuffers.'

Browse source
This commit is contained in:
Anthony 2025-03-05 17:04:53 +08:00
parent d67570ab21
commit f4970a92f4
1 changed files with 99 additions and 64 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

163
web/src/services/AudioService.js
View file

@ -258,29 +258,56 @@ export class AudioService {
} }
processNextOperation() { processNextOperation() {
if (this.sourceBuffer.updating || this.pendingOperations.length === 0) { if (this.sourceBuffer.updating || this.pendingOperations.length === 0) {
return; return;
} }
// Don't process if audio is in error state // Don't process if audio is in error state
if (this.audio.error) { if (this.audio.error) {
console.warn('Skipping operation due to audio error'); console.warn("Skipping operation due to audio error");
return; return;
} }
const operation = this.pendingOperations.shift(); const operation = this.pendingOperations.shift();
try { try {
this.sourceBuffer.appendBuffer(operation.chunk); this.sourceBuffer.appendBuffer(operation.chunk);
operation.resolve();
} catch (error) { // Set up event listeners
operation.reject(error); const onUpdateEnd = () => {
// Only continue processing if it's not a fatal error operation.resolve();
if (error.name !== 'InvalidStateError') { this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.processNextOperation(); this.sourceBuffer.removeEventListener(
} "updateerror",
} onUpdateError
} );
// Process the next operation
this.processNextOperation();
};
const onUpdateError = (event) => {
operation.reject(event);
this.sourceBuffer.removeEventListener("updateend", onUpdateEnd);
this.sourceBuffer.removeEventListener(
"updateerror",
onUpdateError
);
// Decide whether to continue processing
if (event.name !== "InvalidStateError") {
this.processNextOperation();
}
};
this.sourceBuffer.addEventListener("updateend", onUpdateEnd);
this.sourceBuffer.addEventListener("updateerror", onUpdateError);
} catch (error) {
operation.reject(error);
// Only continue processing if it's not a fatal error
if (error.name !== "InvalidStateError") {
this.processNextOperation();
}
}
}
play() { play() {
if (this.audio && this.audio.readyState >= 2 && !this.audio.error) { if (this.audio && this.audio.readyState >= 2 && !this.audio.error) {
@ -360,56 +387,64 @@ export class AudioService {
} }
cancel() { cancel() {
if (this.controller) { if (this.controller) {
this.controller.abort(); this.controller.abort();
this.controller = null; this.controller = null;
} }
if (this.audio) {
this.audio.pause();
this.audio.src = '';
this.audio = null;
}
if (this.mediaSource && this.mediaSource.readyState === 'open') { if (this.audio) {
try { this.audio.pause();
this.mediaSource.endOfStream(); this.audio.src = "";
} catch (e) { this.audio = null;
// Ignore errors during cleanup }
}
}
this.mediaSource = null; if (this.mediaSource && this.mediaSource.readyState === "open") {
this.sourceBuffer = null; try {
this.serverDownloadPath = null; this.mediaSource.endOfStream();
this.pendingOperations = []; } catch (e) {
// Ignore errors during cleanup
}
}
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
} }
cleanup() { cleanup() {
if (this.audio) { if (this.audio) {
this.eventListeners.forEach((listeners, event) => { this.eventListeners.forEach((listeners, event) => {
listeners.forEach(callback => { listeners.forEach((callback) => {
this.audio.removeEventListener(event, callback); this.audio.removeEventListener(event, callback);
}); });
}); });
this.audio.pause();
this.audio.src = '';
this.audio = null;
}
if (this.mediaSource && this.mediaSource.readyState === 'open') { this.audio.pause();
try { this.audio.src = "";
this.mediaSource.endOfStream(); this.audio = null;
} catch (e) { }
// Ignore errors during cleanup
}
}
this.mediaSource = null; if (this.mediaSource && this.mediaSource.readyState === "open") {
this.sourceBuffer = null; try {
this.serverDownloadPath = null; this.mediaSource.endOfStream();
this.pendingOperations = []; } catch (e) {
// Ignore errors during cleanup
}
}
this.mediaSource = null;
if (this.sourceBuffer) {
this.sourceBuffer.removeEventListener("updateend", () => {});
this.sourceBuffer.removeEventListener("updateerror", () => {});
this.sourceBuffer = null;
}
this.serverDownloadPath = null;
this.pendingOperations = [];
} }
getDownloadUrl() { getDownloadUrl() {