Stream optimizations

This commit is contained in:
killer069 2021-09-13 12:41:10 +05:30
parent 50dc2da1e3
commit 4c486c024a

View File

@ -143,6 +143,8 @@ export class Stream {
this.stream.on('pause', () => { this.stream.on('pause', () => {
this.playing_count++; this.playing_count++;
if(this.data_ended){ if(this.data_ended){
this.bytes_count = 0
this.per_sec_bytes = 0
this.cleanup() this.cleanup()
this.stream.removeAllListeners('pause') this.stream.removeAllListeners('pause')
} }
@ -168,8 +170,6 @@ export class Stream {
this.request?.destroy() this.request?.destroy()
this.request = null this.request = null
this.url = '' this.url = ''
this.bytes_count = 0
this.per_sec_bytes = 0
} }
private async loop(){ private async loop(){
@ -183,7 +183,7 @@ export class Stream {
"range" : `bytes=${this.bytes_count}-${end >= this.content_length ? '' : end}` "range" : `bytes=${this.bytes_count}-${end >= this.content_length ? '' : end}`
} }
}) })
if(Number(stream.statusCode) >= 400 && this.bytes_count === 0){ if(Number(stream.statusCode) >= 400){
this.cleanup() this.cleanup()
await this.retry() await this.retry()
this.loop() this.loop()