Index: sdk/lib/_internal/pub_generated/lib/src/barback/admin_server.dart |
diff --git a/sdk/lib/_internal/pub/lib/src/barback/admin_server.dart b/sdk/lib/_internal/pub_generated/lib/src/barback/admin_server.dart |
similarity index 85% |
copy from sdk/lib/_internal/pub/lib/src/barback/admin_server.dart |
copy to sdk/lib/_internal/pub_generated/lib/src/barback/admin_server.dart |
index 057a5888e91435ccca26a10c131a025d0e40b7f1..36bb621e5799764d4552fa943452486e7ab62aec 100644 |
--- a/sdk/lib/_internal/pub/lib/src/barback/admin_server.dart |
+++ b/sdk/lib/_internal/pub_generated/lib/src/barback/admin_server.dart |
@@ -27,8 +27,8 @@ class AdminServer extends BaseServer { |
shelf.Handler _handler; |
/// Creates a new server and binds it to [port] of [host]. |
- static Future<AdminServer> bind(AssetEnvironment environment, |
- String host, int port) { |
+ static Future<AdminServer> bind(AssetEnvironment environment, String host, |
+ int port) { |
return bindServer(host, port).then((server) { |
log.fine('Bound admin server to $host:$port.'); |
return new AdminServer._(environment, server); |
@@ -37,9 +37,8 @@ class AdminServer extends BaseServer { |
AdminServer._(AssetEnvironment environment, HttpServer server) |
: super(environment, server) { |
- _handler = new shelf.Cascade() |
- .add(webSocketHandler(_handleWebSocket)) |
- .add(_handleHttp).handler; |
+ _handler = new shelf.Cascade().add( |
+ webSocketHandler(_handleWebSocket)).add(_handleHttp).handler; |
} |
/// Closes the server and all Web Socket connections. |
@@ -56,7 +55,8 @@ class AdminServer extends BaseServer { |
// TODO(rnystrom): Actually respond to requests once there is an admin |
// interface. See #16954. |
logRequest(request, "501 Not Implemented"); |
- return new shelf.Response(501, |
+ return new shelf.Response( |
+ 501, |
body: "Currently this server only accepts Web Socket connections."); |
} |
@@ -64,8 +64,7 @@ class AdminServer extends BaseServer { |
void _handleWebSocket(CompatibleWebSocket socket) { |
_webSockets.add(socket); |
var api = new WebSocketApi(socket, environment); |
- api.listen() |
- .whenComplete(() => _webSockets.remove(api)) |
- .catchError(addError); |
+ api.listen().whenComplete( |
+ () => _webSockets.remove(api)).catchError(addError); |
} |
} |