viewVideo,
wait,
waitJobs,
+ waitUntilLiveEnded,
waitUntilLivePublished,
waitUntilLiveStarts,
waitUntilLog
}
await stopFfmpeg(command)
+ await waitUntilLiveEnded(servers[0].url, servers[0].accessToken, liveVideoUUID)
+
await waitJobs(servers)
for (const stateChanges of [ localStateChanges, remoteStateChanges ]) {
return waitWhileLiveState(url, token, videoId, VideoState.PUBLISHED)
}
+function waitUntilLiveEnded (url: string, token: string, videoId: number | string) {
+ return waitWhileLiveState(url, token, videoId, VideoState.LIVE_ENDED)
+}
+
async function waitWhileLiveState (url: string, token: string, videoId: number | string, state: VideoState) {
let video: VideoDetails
checkLiveCleanup,
stopFfmpeg,
sendRTMPStreamInVideo,
+ waitUntilLiveEnded,
waitFfmpegUntilError,
sendRTMPStream,
testFfmpegStreamError