Limit number of simultaneous connections to prevent SocketExceptions

Author: Anna Gringauze

dwds/lib/src/readers/proxy_server_asset_reader.dart

@@ -29,10 +29,13 @@ class ProxyServerAssetReader implements AssetReader {
     root ??= '';
     isHttps ??= false;
     var scheme = isHttps ? 'https://' : 'http://';
+    var inner = HttpClient()
+      ..maxConnectionsPerHost = 200
+      ..idleTimeout = const Duration(seconds: 30)
+      ..connectionTimeout = const Duration(seconds: 30);
     _client = isHttps
-        ? IOClient(
-            HttpClient()..badCertificateCallback = (cert, host, port) => true)
-        : http.Client();
+        ? IOClient(inner..badCertificateCallback = (cert, host, port) => true)
+        : IOClient(inner);
     var url = '$scheme$host:$assetServerPort/';
     if (root?.isNotEmpty ?? false) url += '$root/';
     _handler = proxyHandler(url, client: _client);

dwds/test/fixtures/context.dart

@@ -18,6 +18,7 @@ import 'package:dwds/src/utilities/dart_uri.dart';
 import 'package:dwds/src/utilities/shared.dart';
 import 'package:frontend_server_common/src/resident_runner.dart';
 import 'package:http/http.dart';
+import 'package:http/io_client.dart';
 import 'package:logging/logging.dart' as logging;
 import 'package:path/path.dart' as p;
 import 'package:shelf/shelf.dart';
@@ -133,7 +134,10 @@ class TestContext {
     try {
       configureLogWriter();
 
-      client = Client();
+      client = IOClient(HttpClient()
+        ..maxConnectionsPerHost = 200
+        ..idleTimeout = const Duration(seconds: 30)
+        ..connectionTimeout = const Duration(seconds: 30));
 
       var systemTempDir = Directory.systemTemp;
       _outputDir = systemTempDir.createTempSync('foo bar');

webdev/lib/src/serve/webdev_server.dart

@@ -11,8 +11,8 @@ import 'package:build_daemon/data/build_status.dart' as daemon;
 import 'package:devtools_server/devtools_server.dart';
 import 'package:dwds/data/build_result.dart';
 import 'package:dwds/dwds.dart';
-import 'package:http/http.dart';
 import 'package:http/http.dart' as http;
+import 'package:http/io_client.dart';
 import 'package:http_multi_server/http_multi_server.dart';
 import 'package:shelf/shelf.dart';
 import 'package:shelf/shelf_io.dart' as shelf_io;
@@ -104,7 +104,10 @@ class WebDevServer {
     });
 
     var cascade = Cascade();
-    var client = Client();
+    var client = IOClient(HttpClient()
+      ..maxConnectionsPerHost = 200
+      ..idleTimeout = const Duration(seconds: 30)
+      ..connectionTimeout = const Duration(seconds: 30));
     var assetHandler = proxyHandler(
         'http://localhost:${options.daemonPort}/${options.target}/',
         client: client);