Merge branch 'feature/update-deps' into develop

Author: basicdays

.babelrc

@@ -1,7 +1,6 @@
 # project
 /.nyc_output/
 /build/
-/coverage/
 /scratch/
 
 # node

.gitignore

@@ -1,8 +1,7 @@
 language: node_js
 node_js:
   - 'node'
+  - '8'
   - '6'
-  - '4.5'
-  - '4'
 install: make -j4 build
 script: make full-test

.idea/jsLibraryMappings.xml

@@ -66,7 +66,6 @@ test: build
 
 cover: node_modules
 	cd lib && BABEL_ENV=cover nyc ${test_command}
-	mv lib/coverage .
 
 clean:
 	rm -rf build .nyc_output

.idea/runConfigurations/build.xml

@@ -3,18 +3,18 @@
 
 ## Overview
 
-`stream-to-async-iterator` provides a wrapper that implements `Symbol.asyncIterator`. This will allow streams to be usable
-as async iterables that can be used in for-await-of loops.
+`stream-to-async-iterator` provides a wrapper that implements `Symbol.asyncIterator`. This will allow streams to be
+usable as async iterables that can be used in for-await-of loops.
 
-Supports node.js 4 and up.
+Supports node.js 6 and up.
 
 ## Installation
 
 ```
 $ npm install stream-to-async-iterator
 ```
 
-The examples provides use async/await syntax for for-of loops. This assumes you are in an environment that natively
+The included examples use async/await syntax for for-of loops. This assumes you are in an environment that natively
 supports this new syntax, or that you use a tool such as Babel. In addition, for async iterators to work properly,
 the `Symbol.asyncIterator` symbol must be defined. Core-js or `babel-polyfill` can both help with that.
 

.idea/runConfigurations/cover.xml

@@ -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,13 +109,7 @@ export default class StreamToAsyncIterator<TVal> {
         stream.once('end', handleStreamEnd);
     }
 
-    _stream: Readable;
-    _error: ?Error;
-    _state: Symbol;
-    _size: ?number;
-    _rejections: Set<Reject>;
-
-    //todo: flow is now working with this method in place
+    //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 };
     }
 }
 

.idea/runConfigurations/flow.xml

@@ -1,6 +1,5 @@
 // @flow
 import 'source-map-support/register';
-import 'babel-polyfill';
 
 
 Error.stackTraceLimit = Infinity;