From 3a0c2a77b1a6626699514ddaf8135f4397175443 Mon Sep 17 00:00:00 2001 From: Chocobozzz Date: Tue, 2 May 2023 13:51:06 +0200 Subject: Enable external plugins to test the PR --- packages/peertube-runner/server/process/shared/process-live.ts | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'packages/peertube-runner/server/process') diff --git a/packages/peertube-runner/server/process/shared/process-live.ts b/packages/peertube-runner/server/process/shared/process-live.ts index 5a3b596a2..b17b51c7c 100644 --- a/packages/peertube-runner/server/process/shared/process-live.ts +++ b/packages/peertube-runner/server/process/shared/process-live.ts @@ -204,8 +204,8 @@ export class ProcessLiveRTMPHLSTranscoding { // --------------------------------------------------------------------------- - private sendDeletedChunkUpdate (deletedChunk: string) { - if (this.ended) return + private sendDeletedChunkUpdate (deletedChunk: string): Promise { + if (this.ended) return Promise.resolve() logger.debug(`Sending removed live chunk ${deletedChunk} update`) @@ -230,8 +230,8 @@ export class ProcessLiveRTMPHLSTranscoding { return this.updateWithRetry(payload) } - private sendAddedChunkUpdate (addedChunk: string) { - if (this.ended) return + private sendAddedChunkUpdate (addedChunk: string): Promise { + if (this.ended) return Promise.resolve() logger.debug(`Sending added live chunk ${addedChunk} update`) @@ -257,7 +257,7 @@ export class ProcessLiveRTMPHLSTranscoding { return this.updateWithRetry(payload) } - private async updateWithRetry (payload: LiveRTMPHLSTranscodingUpdatePayload, currentTry = 1) { + private async updateWithRetry (payload: LiveRTMPHLSTranscodingUpdatePayload, currentTry = 1): Promise { if (this.ended || this.errored) return try { -- cgit v1.2.3