Histmy/play-dl-fix
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

LiveStream Memory issue fix

Browse Source
This commit is contained in:
killer069 2021-08-21 18:55:45 +05:30
parent 3aa3aeab3e
commit b776a4868f
1 changed files with 16 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
play-dl/YouTube/classes/LiveStream.ts
View File

@ -34,7 +34,10 @@ export class LiveStreaming{
} }
private async live_loop(){ private async live_loop(){
if(this.stream.destroyed) this.cleanup() if(this.stream.destroyed) {
this.cleanup()
return
}
await this.manifest_getter() await this.manifest_getter()
this.segments_urls.splice(0, (this.segments_urls.length / 2)) this.segments_urls.splice(0, (this.segments_urls.length / 2))
if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0]) if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0])
@ -61,7 +64,10 @@ export class LiveStreaming{
} }
private async looping(){ private async looping(){
if(this.stream.destroyed) this.cleanup() if(this.stream.destroyed){
this.cleanup()
return
}
await this.manifest_getter() await this.manifest_getter()
for await (let url of this.segments_urls){ for await (let url of this.segments_urls){
await (async () => { await (async () => {
@ -97,7 +103,10 @@ export class LiveStreaming{
} }
private async start(){ private async start(){
if(this.stream.destroyed) this.cleanup() if(this.stream.destroyed){
this.cleanup()
return
}
await this.manifest_getter() await this.manifest_getter()
if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0]) if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0])
for await (let url of this.segments_urls){ for await (let url of this.segments_urls){
@ -156,7 +165,10 @@ export class LiveEnded{
} }
async start(){ async start(){
if(this.stream.destroyed) this.cleanup() if(this.stream.destroyed){
this.cleanup()
return
}
await this.manifest_getter() await this.manifest_getter()
if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0]) if(this.packet_count === 0) this.packet_count = Number(this.segments_urls[0].split('index.m3u8/sq/')[1].split('/')[0])
for await (let url of this.segments_urls){ for await (let url of this.segments_urls){