events: don't call resume after close

PR-URL: #60548Fixes: #60507
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: Gürgün Dayıoğlu <hey@gurgun.day>

Author: ChALkeR

lib/events.js

@@ -1074,7 +1074,7 @@ function on(emitter, event, options = kEmptyObject) {
 constvalue=unconsumedEvents.shift();
 size--;
 if(paused&&size<lowWatermark){
-emitter.resume();
+emitter.resume();// Can not be finished yet
 paused=false;
 }
 returnPromiseResolve(createIterResult(value,false));
@@ -1191,6 +1191,7 @@ function on(emitter, event, options = kEmptyObject) {
 abortListenerDisposable?.[SymbolDispose]();
 removeAll();
 finished=true;
+paused=false;
 constdoneResult=createIterResult(undefined,true);
 while(!unconsumedPromises.isEmpty()){
 unconsumedPromises.shift().resolve(doneResult);

test/parallel/test-readline-async-iterators.js

@@ -17,6 +17,7 @@ const testContents = [
 'line 1',
 'line 1\nline 2 南越国是前203年至前111年存在于岭南地区的一个国家\nline 3\ntrailing',
 'line 1\nline 2\nline 3 ends with newline\n',
+Array(1e4).fill(0).map((_,i)=>i).join('\n'),// More that 2 * highWaterMark
 ];
 
 asyncfunctiontestSimple(){
@@ -43,6 +44,29 @@ async function testSimple() {
 }
 }
 
+// Same as testSimple, but with Readable.from() instead of fs.createReadStream
+asyncfunctiontestReadableFrom(){
+for(constfileContentoftestContents){
+constreadable=Readable.from([fileContent]);
+constrli=readline.createInterface({
+input: readable,
+crlfDelay: Infinity
+});
+
+constiteratedLines=[];
+forawait(constkofrli){
+iteratedLines.push(k);
+}
+
+constexpectedLines=fileContent.split('\n');
+if(expectedLines[expectedLines.length-1]===''){
+expectedLines.pop();
+}
+assert.deepStrictEqual(iteratedLines,expectedLines);
+assert.strictEqual(iteratedLines.join(''),fileContent.replace(/\n/g,''));
+}
+}
+
 asyncfunctiontestMutual(){
 for(constfileContentoftestContents){
 fs.writeFileSync(filename,fileContent);
@@ -115,6 +139,7 @@ async function testSlowStreamForLeaks() {
 }
 
 testSimple()
+.then(testReadableFrom)
 .then(testMutual)
 .then(testSlowStreamForLeaks)
 .then(common.mustCall());