diff --git a/lib/dest/write-contents/write-stream.js b/lib/dest/write-contents/write-stream.js index fb411552..c3c52fd1 100644 --- a/lib/dest/write-contents/write-stream.js +++ b/lib/dest/write-contents/write-stream.js @@ -3,7 +3,7 @@ var fs = require('graceful-fs'); var fo = require('../../file-operations'); -var streamFile = require('../../src/get-contents/stream-file'); +var readStream = require('../../src/get-contents/read-stream'); function writeStream(writePath, file, written) { var opt = { @@ -24,7 +24,7 @@ function writeStream(writePath, file, written) { file.contents.pipe(outStream, { end: false }); function readStreamEnd() { - streamFile(file, complete); + readStream(file, complete); } function end(propagatedErr) { diff --git a/lib/src/get-contents/index.js b/lib/src/get-contents/index.js index e08043a9..a4040784 100644 --- a/lib/src/get-contents/index.js +++ b/lib/src/get-contents/index.js @@ -2,9 +2,9 @@ var through2 = require('through2'); var readDir = require('./read-dir'); +var readStream = require('./read-stream'); +var readBuffer = require('./read-buffer'); var readSymbolicLink = require('./read-symbolic-link'); -var bufferFile = require('./buffer-file'); -var streamFile = require('./stream-file'); function getContents(opt) { return through2.obj(opt, function(file, enc, cb) { @@ -20,11 +20,11 @@ function getContents(opt) { // Read and pass full contents if (opt.buffer !== false) { - return bufferFile(file, opt, cb); + return readBuffer(file, opt, cb); } // Don't buffer anything - just pass streams - return streamFile(file, opt, cb); + return readStream(file, opt, cb); }); } diff --git a/lib/src/get-contents/buffer-file.js b/lib/src/get-contents/read-buffer.js similarity index 100% rename from lib/src/get-contents/buffer-file.js rename to lib/src/get-contents/read-buffer.js diff --git a/lib/src/get-contents/stream-file.js b/lib/src/get-contents/read-stream.js similarity index 100% rename from lib/src/get-contents/stream-file.js rename to lib/src/get-contents/read-stream.js