From e554efaee43892cf4612c857deb2a182c6b9ac4d Mon Sep 17 00:00:00 2001
From: Jean Lauliac <jeanlauliac@fb.com>
Date: Tue, 30 May 2017 04:48:26 -0700
Subject: [PATCH] packager: AsyncTaskGroup: @flow

Reviewed By: cpojer

Differential Revision: D5137195

fbshipit-source-id: 7d61d8f920ea5db7f70415e9f8fb7749a279bec8
---
 .../src/node-haste/lib/AsyncTaskGroup.js           | 14 +++++++++++---
 1 file changed, 11 insertions(+), 3 deletions(-)

diff --git a/packages/metro-bundler/src/node-haste/lib/AsyncTaskGroup.js b/packages/metro-bundler/src/node-haste/lib/AsyncTaskGroup.js
index 7f99b25e..81235595 100644
--- a/packages/metro-bundler/src/node-haste/lib/AsyncTaskGroup.js
+++ b/packages/metro-bundler/src/node-haste/lib/AsyncTaskGroup.js
@@ -5,23 +5,31 @@
  * This source code is licensed under the BSD-style license found in the
  * LICENSE file in the root directory of this source tree. An additional grant
  * of patent rights can be found in the PATENTS file in the same directory.
+ *
+ * @flow
  */
+
 'use strict';
 
-module.exports = class AsyncTaskGroup {
+module.exports = class AsyncTaskGroup<TTaskHandle> {
+  _runningTasks: Set<TTaskHandle>;
+  _resolve: ?() => void;
+  done: Promise<void>;
+
   constructor() {
     this._runningTasks = new Set();
     this._resolve = null;
     this.done = new Promise(resolve => this._resolve = resolve);
   }
 
-  start(taskHandle) {
+  start(taskHandle: TTaskHandle) {
     this._runningTasks.add(taskHandle);
   }
 
-  end(taskHandle) {
+  end(taskHandle: TTaskHandle) {
     const runningTasks = this._runningTasks;
     if (runningTasks.delete(taskHandle) && runningTasks.size === 0) {
+      /* $FlowFixMe: could be null */
       this._resolve();
     }
   }