|
|
@ -64,7 +64,7 @@ const destroyStream = function (stream) {
|
|
|
|
try { stream.close(); } catch (err) { console.error(err); }
|
|
|
|
try { stream.close(); } catch (err) { console.error(err); }
|
|
|
|
setTimeout(function () {
|
|
|
|
setTimeout(function () {
|
|
|
|
try { stream.destroy(); } catch (err) { console.error(err); }
|
|
|
|
try { stream.destroy(); } catch (err) { console.error(err); }
|
|
|
|
}, 5000);
|
|
|
|
}, 15000);
|
|
|
|
};
|
|
|
|
};
|
|
|
|
|
|
|
|
|
|
|
|
const ensureStreamCloses = function (stream, id, ms) {
|
|
|
|
const ensureStreamCloses = function (stream, id, ms) {
|
|
|
@ -729,7 +729,7 @@ var getChannel = function (env, id, _callback) {
|
|
|
|
delete env.channels[id];
|
|
|
|
delete env.channels[id];
|
|
|
|
destroyStream(channel.writeStream, path);
|
|
|
|
destroyStream(channel.writeStream, path);
|
|
|
|
//console.log("closing writestream");
|
|
|
|
//console.log("closing writestream");
|
|
|
|
}, 30000);
|
|
|
|
}, 120000);
|
|
|
|
channel.delayClose();
|
|
|
|
channel.delayClose();
|
|
|
|
env.channels[id] = channel;
|
|
|
|
env.channels[id] = channel;
|
|
|
|
done(void 0, channel);
|
|
|
|
done(void 0, channel);
|
|
|
|