diff options
| author | isaacs <i@izs.me> | 2013-07-26 14:38:08 -0700 |
|---|---|---|
| committer | isaacs <i@izs.me> | 2013-08-01 15:08:01 -0700 |
| commit | 22c68fdc1dae40f0ed9c71a02f66e5b2c6353691 (patch) | |
| tree | b6d14cad6f5a9ba78172f77c5c2ec10b8a6cb89c /lib/_stream_transform.js | |
| parent | 9a29aa8c552eb2b120c101c1cfd66ba565a17ed5 (diff) | |
| download | node-new-22c68fdc1dae40f0ed9c71a02f66e5b2c6353691.tar.gz | |
src: Replace macros with util functions
Diffstat (limited to 'lib/_stream_transform.js')
| -rw-r--r-- | lib/_stream_transform.js | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/lib/_stream_transform.js b/lib/_stream_transform.js index 735f2cf5eb..d2bdcffe66 100644 --- a/lib/_stream_transform.js +++ b/lib/_stream_transform.js @@ -92,7 +92,7 @@ function afterTransform(stream, er, data) { ts.writechunk = null; ts.writecb = null; - if (!IS_NULL_OR_UNDEFINED(data)) + if (!util.isNullOrUndefined(data)) stream.push(data); if (cb) @@ -126,7 +126,7 @@ function Transform(options) { this._readableState.sync = false; this.once('prefinish', function() { - if (IS_FUNCTION(this._flush)) + if (util.isFunction(this._flush)) this._flush(function(er) { done(stream, er); }); @@ -174,7 +174,7 @@ Transform.prototype._write = function(chunk, encoding, cb) { Transform.prototype._read = function(n) { var ts = this._transformState; - if (!IS_NULL(ts.writechunk) && ts.writecb && !ts.transforming) { + if (!util.isNull(ts.writechunk) && ts.writecb && !ts.transforming) { ts.transforming = true; this._transform(ts.writechunk, ts.writeencoding, ts.afterTransform); } else { |