Fix bug around handling of failures in spawnWorker calls

CHANGELOG.md

@@ -1,3 +1,8 @@
+## 1.1.1
+
+* Fix a bug where if spawnWorker threw an error, work requests would hang
+  forever instead of failing.
+
 ## 1.1.0
 
 * Add constructors with named parameters to

lib/src/driver/driver.dart

@@ -120,6 +120,10 @@ class BazelWorkerDriver {
           _readyWorkers.remove(worker);
           _runWorkQueue();
         });
+      }).onError<Object>((e, s) {
+        _spawningWorkers.remove(futureWorker);
+        if (attempt.responseCompleter.isCompleted) return;
+        attempt.responseCompleter.completeError(e, s);
       });
     }
     // Recursively calls itself until one of the bail out conditions are met.

pubspec.yaml

@@ -1,5 +1,5 @@
 name: bazel_worker
-version: 1.1.0
+version: 1.1.1
 description: >-
   Protocol and utilities to implement or invoke persistent bazel workers.
 repository: https://github.com/dart-lang/bazel_worker

test/driver_test.dart

@@ -139,6 +139,12 @@ void main() {
       });
     });
 
+    test('handles spawnWorker failures', () async {
+      driver = BazelWorkerDriver(() async => throw StateError('oh no!'),
+          maxRetries: 0);
+      expect(driver!.doWork(WorkRequest()), throwsA(isA<StateError>()));
+    });
+
     tearDown(() async {
       await driver?.terminateWorkers();
       expect(MockWorker.liveWorkers, isEmpty);