fixuP

Author: ronag

lib/events.js

@@ -87,6 +87,7 @@ const{
 
 constkCapture=Symbol('kCapture');
 constkErrorMonitor=Symbol('events.errorMonitor');
+constkShapeMode=Symbol('shapeMode');
 constkMaxEventTargetListeners=Symbol('events.maxEventTargetListeners');
 constkMaxEventTargetListenersWarned=
 Symbol('events.maxEventTargetListenersWarned');
@@ -344,6 +345,9 @@ EventEmitter.init = function(opts){
 this._events===ObjectGetPrototypeOf(this)._events){
 this._events={__proto__: null};
 this._eventsCount=0;
+this[kShapeMode]=false;
+}else{
+this[kShapeMode]=true;
 }
 
 this._maxListeners=this._maxListeners||undefined;
@@ -686,9 +690,13 @@ EventEmitter.prototype.removeListener =
 returnthis;
 
 if(list===listener||list.listener===listener){
-if(--this._eventsCount===0)
+this._eventsCount-=1;
+
+if(this[kShapeMode]){
+events[type]=undefined;
+}elseif(this._eventsCount===0){
 this._events={__proto__: null};
-else{
+}else{
 deleteevents[type];
 if(events.removeListener)
 this.emit('removeListener',type,list.listener||listener);
@@ -750,6 +758,7 @@ EventEmitter.prototype.removeAllListeners =
 else
 deleteevents[type];
 }
+this[kShapeMode]=false;
 returnthis;
 }
 
@@ -762,6 +771,7 @@ EventEmitter.prototype.removeAllListeners =
 this.removeAllListeners('removeListener');
 this._events={__proto__: null};
 this._eventsCount=0;
+this[kShapeMode]=false;
 returnthis;
 }
 

lib/internal/streams/duplex.js

@@ -76,6 +76,8 @@ function Duplex(options){
 readable: undefined,
 pipe: undefined,
 unpipe: undefined,
+[destroyImpl.kConstruct]: undefined,
+[destroyImpl.kDestroy]: undefined,
 };
 
 this._readableState=newReadable.ReadableState(options,this,true);

lib/internal/streams/readable.js

@@ -326,6 +326,8 @@ function Readable(options){
 readable: undefined,
 pipe: undefined,
 unpipe: undefined,
+[destroyImpl.kConstruct]: undefined,
+[destroyImpl.kDestroy]: undefined,
 };
 
 this._readableState=newReadableState(options,this,false);

lib/internal/streams/writable.js

@@ -388,6 +388,8 @@ function Writable(options){
 prefinish: undefined,
 finish: undefined,
 drain: undefined,
+[destroyImpl.kConstruct]: undefined,
+[destroyImpl.kDestroy]: undefined,
 };
 
 this._writableState=newWritableState(options,this,false);

test/parallel/test-readline-promises-interface.js

@@ -20,7 +20,7 @@ class FakeInput extends EventEmitter{
 }
 
 functionisWarned(emitter){
-for(constnameinemitter){
+for(constnameofObject.keys(emitter)){
 constlisteners=emitter[name];
 if(listeners.warned)returntrue;
 }