aboutsummaryrefslogtreecommitdiff
path: root/node_modules/lazystream/test/fs_test.js
diff options
context:
space:
mode:
authorFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
committerFlorian Dold <florian.dold@gmail.com>2019-03-27 21:01:33 +0100
commitcc97a4dd2a967e1c2273bd5f4c5f49a5bf2e2585 (patch)
tree92c5d88706a6ffc654d1b133618d357890e7096b /node_modules/lazystream/test/fs_test.js
parent3771b4d6b67b34c130f3a9a1a15f42deefdb2eda (diff)
remove node_modules
Diffstat (limited to 'node_modules/lazystream/test/fs_test.js')
-rw-r--r--node_modules/lazystream/test/fs_test.js69
1 files changed, 0 insertions, 69 deletions
diff --git a/node_modules/lazystream/test/fs_test.js b/node_modules/lazystream/test/fs_test.js
deleted file mode 100644
index 149b1c4a0..000000000
--- a/node_modules/lazystream/test/fs_test.js
+++ /dev/null
@@ -1,69 +0,0 @@
-
-var stream = require('../lib/lazystream');
-var fs = require('fs');
-var tmpDir = 'test/tmp/';
-var readFile = 'test/data.md';
-var writeFile = tmpDir + 'data.md';
-
-exports.fs = {
- readwrite: function(test) {
- var readfd, writefd;
-
- var readable = new stream.Readable(function() {
- return fs.createReadStream(readFile)
- .on('open', function(fd) {
- readfd = fd;
- })
- .on('close', function() {
- readfd = undefined;
- step();
- });
- });
-
- var writable = new stream.Writable(function() {
- return fs.createWriteStream(writeFile)
- .on('open', function(fd) {
- writefd = fd;
- })
- .on('close', function() {
- writefd = undefined;
- step();
- });
- });
-
- test.expect(3);
-
- test.equal(readfd, undefined, 'Input file should not be opened until read');
- test.equal(writefd, undefined, 'Output file should not be opened until write');
-
- if (!fs.existsSync(tmpDir)) {
- fs.mkdirSync(tmpDir);
- }
- if (fs.existsSync(writeFile)) {
- fs.unlinkSync(writeFile);
- }
-
- readable.on('end', function() { step(); });
- writable.on('end', function() { step(); });
-
- var steps = 0;
- function step() {
- steps += 1;
- if (steps == 4) {
- var input = fs.readFileSync(readFile);
- var output = fs.readFileSync(writeFile);
-
- test.ok(input >= output && input <= output, 'Should be equal');
-
- fs.unlinkSync(writeFile);
- fs.rmdirSync(tmpDir);
-
- test.done();
- }
- };
-
- readable.pipe(writable);
- }
-};
-
-