fs: do not emit open and read if stream destroyed

lib/internal/fs/streams.js

@@ -132,6 +132,13 @@ ReadStream.prototype.open = function() {
     }
 
     this.fd = fd;
+
+    if (this.destroyed) {
+      // swallow the error to prevent error from emitting after close.
+      closeFsStream(this, () => {});
+      return;
+    }
+
     this.emit('open', fd);
     this.emit('ready');
     // start the flow of data.
@@ -204,8 +211,9 @@ ReadStream.prototype._read = function(n) {
 };
 
 ReadStream.prototype._destroy = function(err, cb) {
+  // if stream is not open it will be closed in open()
   if (typeof this.fd !== 'number') {
-    this.once('open', closeFsStream.bind(null, this, cb, err));
+    cb(err);
     return;
   }
 
@@ -294,6 +302,12 @@ WriteStream.prototype.open = function() {
     }
 
     this.fd = fd;
+
+    if (this.destroyed) {
+      closeFsStream(this, () => {});
+      return;
+    }
+
     this.emit('open', fd);
     this.emit('ready');
   });

test/parallel/test-fs-stream-no-events-after-destroy.js

@@ -0,0 +1,19 @@
+'use strict';
+const common = require('../common');
+const fs = require('fs');
+const assert = require('assert');
+
+const tmpdir = require('../common/tmpdir');
+tmpdir.refresh();
+
+const test = (stream) => {
+  const err = new Error('DESTROYED');
+  stream.destroy(err);
+  stream.on('open', common.mustNotCall());
+  stream.on('ready', common.mustNotCall());
+  stream.on('close', common.mustCall());
+  stream.on('error', common.mustNotCall());
+}
+
+test(fs.createReadStream(__filename));
+test(fs.createWriteStream(`${tmpdir.path}/dummy`));