Got flow to pass'ish

Author: basicdays

.flowconfig

@@ -0,0 +1,2 @@
+[libs]
+decls/

Makefile

@@ -15,7 +15,7 @@ test_command := mocha test --require=test/index --recursive
 # Files
 
 lib_files := $(shell find lib -type f -name *.js)
-lib_asset_files := $(shell find lib -type f ! -name "*.js" ! -name ".eslintrc.*" ! -name "*.orig")
+lib_asset_files := $(shell find lib -type f ! -name "*.js" ! -name "*.js.flow" ! -name ".eslintrc.*" ! -name "*.orig")
 
 build_files := $(lib_files:lib/%=build/%)
 build_asset_files := $(lib_asset_files:lib/%=build/%)

flow-typed/stream-async-iterator.js

@@ -0,0 +1,9 @@
+declare type StreamAsyncIteratorOptions = {
+    size?: number;
+}
+
+declare class StreamAsyncIterator<TData> {
+    constructor(stream: stream$Readable, options?: StreamAsyncIteratorOptions) : StreamAsyncIterator<TData>;
+    @@iterator(): $Iterator<TData, void, void>;
+    next(): IteratorResult<TData, void>;
+}

lib/stream-async-iterator.js

@@ -28,6 +28,7 @@ type Iteration = {
     done: boolean;
     value: any;
 }
+
 type Reject = (err: any) => void;
 
 /**
@@ -99,13 +100,6 @@ export default class StreamAsyncIterator {
     _size: ?number;
     _rejections: Set<Reject>;
 
-    /**
-     * @returns {StreamAsyncIterator} - this
-     */
-    [Symbol.asyncIterator]() {
-        return this;
-    }
-
     /**
      * Returns the next iteration of data. Rejects if the stream errored out.
      * @returns {Promise<StreamAsyncIterator~Iteration>}
@@ -169,3 +163,8 @@ export default class StreamAsyncIterator {
         })
     }
 }
+
+Object.defineProperty(StreamAsyncIterator.prototype, (Symbol: any).asyncIterator, {
+    configurable: true,
+    value: function() {return this;}
+});

lib/test/stream-async-iterator-tests.js

@@ -13,7 +13,7 @@ describe('StreamAsyncIterator', function() {
         const fileStream = fs.createReadStream(filePath, {encoding: 'utf8'});
         const buff = [];
 
-        for await (const value of new StreamAsyncIterator(fileStream)) {
+        for await (const value of (new StreamAsyncIterator(fileStream): any)) {
             buff.push(value);
         }
 
@@ -25,7 +25,7 @@ describe('StreamAsyncIterator', function() {
         const fileStream = fs.createReadStream(filePath, {encoding: 'utf8'});
         const buff = [];
 
-        for await (const value of new StreamAsyncIterator(fileStream, {size: 16})) {
+        for await (const value of (new StreamAsyncIterator(fileStream, {size: 16}): any)) {
             buff.push(value);
         }