Better type checking

Author: basicdays

.flowconfig

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

Makefile

@@ -48,7 +48,7 @@ build: node_modules ${build_files} ${build_asset_files} ${build_package_files}
 
 # Tasks
 
-full-test: lint test cover
+full-test: lint flow test cover
 
 flow:
 	flow

lib/stream-async-iterator.js.flow

@@ -0,0 +1,11 @@
+// @flow
+
+declare type StreamAsyncIteratorOptions = {
+    size?: number;
+}
+
+declare export default class StreamAsyncIterator<TData> {
+    constructor(stream: stream$Readable, options?: StreamAsyncIteratorOptions): StreamAsyncIterator<TData>;
+    @@asyncIterator(): $AsyncIterator<TData, void, void>;
+    next(): Promise<IteratorResult<TData, void>>;
+}

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

@@ -11,9 +11,9 @@ describe('StreamAsyncIterator', function() {
 
     it('should iterate on a node stream', async () => {
         const fileStream = fs.createReadStream(filePath, {encoding: 'utf8'});
-        const buff = [];
+        const buff: Array<string> = [];
 
-        for await (const value of (new StreamAsyncIterator(fileStream): any)) {
+        for await (const value of (new StreamAsyncIterator(fileStream): StreamAsyncIterator<string>)) {
             buff.push(value);
         }
 
@@ -23,9 +23,9 @@ describe('StreamAsyncIterator', function() {
 
     it('should iterate on a node stream with a size', async () => {
         const fileStream = fs.createReadStream(filePath, {encoding: 'utf8'});
-        const buff = [];
+        const buff: Array<string> = [];
 
-        for await (const value of (new StreamAsyncIterator(fileStream, {size: 16}): any)) {
+        for await (const value of (new StreamAsyncIterator(fileStream, {size: 16}): StreamAsyncIterator<string>)) {
             buff.push(value);
         }