Prevent MaxListenersExceededWarning in PassThrough
This commit is contained in:
parent
ea5b25c92d
commit
e83b925467
@ -90,6 +90,7 @@ export class LiveStreaming{
|
|||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
await new Promise((resolve, reject) => {
|
await new Promise((resolve, reject) => {
|
||||||
|
this.request?.unpipe(this.stream)
|
||||||
let stream = got.stream(this.base_url + segment)
|
let stream = got.stream(this.base_url + segment)
|
||||||
this.request = stream
|
this.request = stream
|
||||||
stream.pipe(this.stream, { end : false })
|
stream.pipe(this.stream, { end : false })
|
||||||
@ -148,6 +149,7 @@ export class Stream {
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
let absolute_bytes : number = 0
|
let absolute_bytes : number = 0
|
||||||
|
this.request?.unpipe(this.stream)
|
||||||
let stream = got.stream(this.url, {
|
let stream = got.stream(this.url, {
|
||||||
headers : {
|
headers : {
|
||||||
"range" : `bytes=${this.bytes_count}-`
|
"range" : `bytes=${this.bytes_count}-`
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user