reverts to using once instead of on

Author: AKST

lib/stream-to-async-iterator.js

@@ -165,12 +165,15 @@ export default class StreamAsyncToIterator {
             eventListener = () => {
                 this._state = states.readable;
                 this._rejections.delete(reject);
+
+                // we set this to null to info the clean up not to do anything
+                eventListener = null;
                 resolve();
             };
 
             //on is used here instead of once, because
             //the listener is remove afterwards anyways.
-            this._stream.on('readable', eventListener);
+            this._stream.once('readable', eventListener);
             this._rejections.add(reject);
         });
 
@@ -194,10 +197,12 @@ export default class StreamAsyncToIterator {
             eventListener = () => {
                 this._state = states.ended;
                 this._rejections.delete(reject);
+
+                eventListener = null
                 resolve();
             };
 
-            this._stream.on('end', eventListener);
+            this._stream.once('end', eventListener);
             this._rejections.add(reject);
         });