Fix formatting

Author: basicdays

lib/stream-to-async-iterator.js

@@ -48,6 +48,12 @@ type Reject = (err: any) => void;
  * the options for each iteration.
  */
 export default class StreamToAsyncIterator<TVal> {
+    _stream: Readable;
+    _error: ?Error;
+    _state: Symbol;
+    _size: ?number;
+    _rejections: Set<Reject>;
+
     /**
      * @param {Readable} stream
      * @param {StreamToAsyncIterator~Options} [options]
@@ -65,7 +71,7 @@ export default class StreamToAsyncIterator<TVal> {
          * @private
          * @type {?Error}
          */
-        this._error = null;
+        this._error = undefined;
 
         /**
          * The current state of the iterator (not readable, readable, ended, errored)
@@ -103,12 +109,6 @@ export default class StreamToAsyncIterator<TVal> {
         stream.once('end', handleStreamEnd);
     }
 
-    _stream: Readable;
-    _error: ?Error;
-    _state: Symbol;
-    _size: ?number;
-    _rejections: Set<Reject>;
-
     //todo: flow is not working with this method in place
     // [Symbol.asyncIterator]() {
     //     return this;
@@ -125,16 +125,16 @@ export default class StreamToAsyncIterator<TVal> {
 
             //need to wait until the stream is readable or ended
             try {
-              await Promise.race([read.promise, end.promise]);
-              return this.next();
+                await Promise.race([read.promise, end.promise]);
+                return this.next();
             }
             catch (e) {
-              throw e
+                throw e;
             }
             finally {
-              //need to clean up any hanging event listeners
-              read.cleanup()
-              end.cleanup()
+                //need to clean up any hanging event listeners
+                read.cleanup();
+                end.cleanup();
             }
         } else if (this._state === states.ended) {
             return {done: true};
@@ -164,15 +164,15 @@ export default class StreamToAsyncIterator<TVal> {
         //let is used here instead of const because the exact reference is
         //required to remove it, this is why it is not a curried function that
         //accepts resolve & reject as parameters.
-        let eventListener = null;
+        let eventListener = undefined;
 
         const promise = new Promise((resolve, reject) => {
             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;
+                // we set this to undefined to info the clean up not to do anything
+                eventListener = undefined;
                 resolve();
             };
 
@@ -187,7 +187,7 @@ export default class StreamToAsyncIterator<TVal> {
             this._stream.removeListener('readable', eventListener);
         };
 
-        return { cleanup, promise }
+        return { cleanup, promise };
     }
 
     /**
@@ -196,14 +196,14 @@ export default class StreamToAsyncIterator<TVal> {
      * @returns {Promise}
      */
     _untilEnd(): PromiseWithCleanUp<void> {
-        let eventListener = null;
+        let eventListener = undefined;
 
         const promise = new Promise((resolve, reject) => {
             eventListener = () => {
                 this._state = states.ended;
                 this._rejections.delete(reject);
 
-                eventListener = null
+                eventListener = undefined;
                 resolve();
             };
 
@@ -216,7 +216,7 @@ export default class StreamToAsyncIterator<TVal> {
             this._stream.removeListener('end', eventListener);
         };
 
-        return { cleanup, promise }
+        return { cleanup, promise };
     }
 }