/*!
|
* destroy
|
* Copyright(c) 2014 Jonathan Ong
|
* MIT Licensed
|
*/
|
|
'use strict'
|
|
/**
|
* Module dependencies.
|
* @private
|
*/
|
|
var ReadStream = require('fs').ReadStream
|
var Stream = require('stream')
|
|
/**
|
* Module exports.
|
* @public
|
*/
|
|
module.exports = destroy
|
|
/**
|
* Destroy a stream.
|
*
|
* @param {object} stream
|
* @public
|
*/
|
|
function destroy(stream) {
|
if (stream instanceof ReadStream) {
|
return destroyReadStream(stream)
|
}
|
|
if (!(stream instanceof Stream)) {
|
return stream
|
}
|
|
if (typeof stream.destroy === 'function') {
|
stream.destroy()
|
}
|
|
return stream
|
}
|
|
/**
|
* Destroy a ReadStream.
|
*
|
* @param {object} stream
|
* @private
|
*/
|
|
function destroyReadStream(stream) {
|
stream.destroy()
|
|
if (typeof stream.close === 'function') {
|
// node.js core bug work-around
|
stream.on('open', onOpenClose)
|
}
|
|
return stream
|
}
|
|
/**
|
* On open handler to close stream.
|
* @private
|
*/
|
|
function onOpenClose() {
|
if (typeof this.fd === 'number') {
|
// actually close down the fd
|
this.close()
|
}
|
}
|
