summaryrefslogtreecommitdiff
path: root/deps/npm/node_modules/fstream/lib/proxy-reader.js
diff options
context:
space:
mode:
Diffstat (limited to 'deps/npm/node_modules/fstream/lib/proxy-reader.js')
-rw-r--r--deps/npm/node_modules/fstream/lib/proxy-reader.js100
1 files changed, 51 insertions, 49 deletions
diff --git a/deps/npm/node_modules/fstream/lib/proxy-reader.js b/deps/npm/node_modules/fstream/lib/proxy-reader.js
index a0ece34a2..4f431c9d9 100644
--- a/deps/npm/node_modules/fstream/lib/proxy-reader.js
+++ b/deps/npm/node_modules/fstream/lib/proxy-reader.js
@@ -3,82 +3,84 @@
module.exports = ProxyReader
-var Reader = require("./reader.js")
- , getType = require("./get-type.js")
- , inherits = require("inherits")
- , fs = require("graceful-fs")
+var Reader = require('./reader.js')
+var getType = require('./get-type.js')
+var inherits = require('inherits')
+var fs = require('graceful-fs')
inherits(ProxyReader, Reader)
function ProxyReader (props) {
- var me = this
- if (!(me instanceof ProxyReader)) throw new Error(
- "ProxyReader must be called as constructor.")
+ var self = this
+ if (!(self instanceof ProxyReader)) {
+ throw new Error('ProxyReader must be called as constructor.')
+ }
- me.props = props
- me._buffer = []
- me.ready = false
+ self.props = props
+ self._buffer = []
+ self.ready = false
- Reader.call(me, props)
+ Reader.call(self, props)
}
ProxyReader.prototype._stat = function () {
- var me = this
- , props = me.props
- // stat the thing to see what the proxy should be.
- , stat = props.follow ? "stat" : "lstat"
+ var self = this
+ var props = self.props
+ // stat the thing to see what the proxy should be.
+ var stat = props.follow ? 'stat' : 'lstat'
fs[stat](props.path, function (er, current) {
var type
if (er || !current) {
- type = "File"
+ type = 'File'
} else {
type = getType(current)
}
props[type] = true
- props.type = me.type = type
+ props.type = self.type = type
- me._old = current
- me._addProxy(Reader(props, current))
+ self._old = current
+ self._addProxy(Reader(props, current))
})
}
ProxyReader.prototype._addProxy = function (proxy) {
- var me = this
- if (me._proxyTarget) {
- return me.error("proxy already set")
+ var self = this
+ if (self._proxyTarget) {
+ return self.error('proxy already set')
}
- me._proxyTarget = proxy
- proxy._proxy = me
-
- ; [ "error"
- , "data"
- , "end"
- , "close"
- , "linkpath"
- , "entry"
- , "entryEnd"
- , "child"
- , "childEnd"
- , "warn"
- , "stat"
- ].forEach(function (ev) {
- // console.error("~~ proxy event", ev, me.path)
- proxy.on(ev, me.emit.bind(me, ev))
- })
-
- me.emit("proxy", proxy)
-
- proxy.on("ready", function () {
- // console.error("~~ proxy is ready!", me.path)
- me.ready = true
- me.emit("ready")
+ self._proxyTarget = proxy
+ proxy._proxy = self
+
+ ;[
+ 'error',
+ 'data',
+ 'end',
+ 'close',
+ 'linkpath',
+ 'entry',
+ 'entryEnd',
+ 'child',
+ 'childEnd',
+ 'warn',
+ 'stat'
+ ].forEach(function (ev) {
+ // console.error('~~ proxy event', ev, self.path)
+ proxy.on(ev, self.emit.bind(self, ev))
+ })
+
+ self.emit('proxy', proxy)
+
+ proxy.on('ready', function () {
+ // console.error("~~ proxy is ready!", self.path)
+ self.ready = true
+ self.emit('ready')
})
- var calls = me._buffer
- me._buffer.length = 0
+ var calls = self._buffer
+ self._buffer.length = 0
calls.forEach(function (c) {
proxy[c[0]].apply(proxy, c[1])
})