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

Remove useless Promise and function code

Browse Source
This commit is contained in:
cjh980402 2021-09-04 17:28:53 +09:00
parent f8f5416869
commit 00b90c4a55
2 changed files with 16 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -89,20 +89,18 @@ export class LiveStreaming{
if(Number(segment.split('sq/')[1].split('/')[0]) !== this.packet_count){ if(Number(segment.split('sq/')[1].split('/')[0]) !== this.packet_count){
continue continue
} }
await (async () => { await new Promise(async (resolve, reject) => {
return new Promise(async (resolve, reject) => { let stream = got.stream(this.base_url + segment)
let stream = got.stream(this.base_url + segment) this.request = stream
this.request = stream stream.on('data', (chunk: any) => this.stream.write(chunk))
stream.on('data', (chunk: any) => this.stream.write(chunk)) stream.on('end', () => {
stream.on('end', () => { this.packet_count++
this.packet_count++ resolve('')
resolve('')
})
stream.once('error', (err) => {
this.stream.emit('error', err)
})
}) })
})() stream.once('error', (err) => {
this.stream.emit('error', err)
})
})
} }
this.timer = setTimeout(() => { this.timer = setTimeout(() => {
this.start() this.start()

12
play-dl/YouTube/utils/request.ts
View File

@ -1,11 +1,9 @@
import got, { OptionsOfTextResponseBody } from 'got/dist/source' import got, { OptionsOfTextResponseBody } from 'got/dist/source'
export async function url_get (url : string, options? : OptionsOfTextResponseBody) : Promise<string>{ export async function url_get (url : string, options? : OptionsOfTextResponseBody) : Promise<string>{
return new Promise(async(resolve, reject) => { let response = await got(url, options)
let response = await got(url, options) if(response.statusCode === 200) {
if(response.statusCode === 200) { return response.body
resolve(response.body) }
} else throw `Got ${response.statusCode} from ${url}`
else reject(`Got ${response.statusCode} from ${url}`)
})
} }