m3u8stream
Advanced tools
Comparing version 0.1.2 to 0.1.3
@@ -18,2 +18,3 @@ const PassThrough = require('stream').PassThrough; | ||
var refreshInterval = options.refreshInterval || 600000; // 10 minutes | ||
var requestOptions = options.requestOptions; | ||
@@ -24,3 +25,2 @@ var latestSegment; | ||
segment.pipe(stream, { end: false }); | ||
segment.on('error', callback); | ||
segment.on('end', callback); | ||
@@ -30,3 +30,5 @@ }, { concurrency: 1 }); | ||
var requestQueue = new Queue(function(segmentURL, callback) { | ||
streamQueue.push(miniget(urlResolve(playlistURL, segmentURL)), callback); | ||
var segment = miniget(urlResolve(playlistURL, segmentURL), requestOptions); | ||
segment.on('error', callback); | ||
streamQueue.push(segment, callback); | ||
}, { | ||
@@ -63,3 +65,3 @@ concurrency: chunkReadahead, | ||
fetchingPlaylist = true; | ||
var req = miniget(playlistURL); | ||
var req = miniget(playlistURL, requestOptions); | ||
req.on('error', onError); | ||
@@ -66,0 +68,0 @@ var parser = req.pipe(new m3u8()); |
@@ -9,3 +9,3 @@ { | ||
], | ||
"version": "0.1.2", | ||
"version": "0.1.3", | ||
"repository": { | ||
@@ -12,0 +12,0 @@ "type": "git", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
9254
186