|
|
@@ -43,6 +43,7 @@ function once(fn) {
|
|
|
var call = !called;
|
|
|
called = true;
|
|
|
if(call) fn.apply(this, arguments);
|
|
|
+ else debug('once only callback failed');
|
|
|
};
|
|
|
}
|
|
|
|
|
|
@@ -273,11 +274,12 @@ function HlsStreamReader(src, options) {
|
|
|
if (!stream) return;
|
|
|
|
|
|
if (typeof stream.destroy == 'function') {
|
|
|
- debug('timed out waiting for data');
|
|
|
var duration = self.readState.currentSegment.duration || self.index.target_duration || 10;
|
|
|
self.readState.timer = setTimeout(function() {
|
|
|
- if (self.readState.stream)
|
|
|
+ if (self.readState.stream) {
|
|
|
+ debug('timed out waiting for data');
|
|
|
self.readState.stream.destroy();
|
|
|
+ }
|
|
|
self.readState.timer = null;
|
|
|
}, 1.5*duration*1000);
|
|
|
}
|