|
|
@@ -97,7 +97,7 @@ HlsStreamRecorder.prototype.updateIndex = function(update) {
|
|
|
var rec = this.recorderForUrl(programUrl);
|
|
|
if (!rec || !rec.localUrl) {
|
|
|
var dir = self.variantName(program.info, index);
|
|
|
- rec = new HlsStreamRecorder(self.subreader(programUrl), path.join(self.dst, dir), { startOffset: self.startOffset });
|
|
|
+ rec = new HlsStreamRecorder(self.subreader(programUrl), path.join(self.dst, dir), { startOffset: self.startOffset, collect: self.collect });
|
|
|
rec.localUrl = url.format({pathname: path.join(dir, 'index.m3u8')});
|
|
|
rec.remoteUrl = programUrl;
|
|
|
|
|
|
@@ -121,7 +121,7 @@ HlsStreamRecorder.prototype.updateIndex = function(update) {
|
|
|
var rec = this.recorderForUrl(itemUrl);
|
|
|
if (!rec || !rec.localUrl) {
|
|
|
var dir = self.groupSrcName(groupItem, index);
|
|
|
- rec = new HlsStreamRecorder(self.subreader(itemUrl), path.join(self.dst, dir), { startOffset: self.startOffset });
|
|
|
+ rec = new HlsStreamRecorder(self.subreader(itemUrl), path.join(self.dst, dir), { startOffset: self.startOffset, collect: self.collect });
|
|
|
rec.localUrl = url.format({pathname: path.join(dir, 'index.m3u8')});
|
|
|
rec.remoteUrl = itemUrl;
|
|
|
|