Index: sdk/lib/_internal/pub/lib/src/barback/server.dart |
diff --git a/sdk/lib/_internal/pub/lib/src/barback/server.dart b/sdk/lib/_internal/pub/lib/src/barback/server.dart |
index f491aab1ab13291b9b78b0263cd5dd66179a891e..cb6c46eb364118de5dc42c1230f0bc46a8e92aa9 100644 |
--- a/sdk/lib/_internal/pub/lib/src/barback/server.dart |
+++ b/sdk/lib/_internal/pub/lib/src/barback/server.dart |
@@ -61,7 +61,7 @@ class BarbackServer { |
/// root package. |
static Future<BarbackServer> bind(String host, int port, Barback barback, |
String rootPackage) { |
- return HttpServer.bind(host, port) |
+ return Chain.track(HttpServer.bind(host, port)) |
.then((server) => new BarbackServer._(server, barback, rootPackage)); |
} |
@@ -69,7 +69,7 @@ class BarbackServer { |
: _server = server, |
port = server.port, |
address = server.address { |
- _server.listen(_handleRequest, onError: (error, stackTrace) { |
+ Chain.track(_server).listen(_handleRequest, onError: (error, stackTrace) { |
_resultsController.addError(error, stackTrace); |
close(); |
}); |
@@ -115,7 +115,7 @@ class BarbackServer { |
_resultsController.add( |
new BarbackServerResult._success(request.uri, id)); |
// TODO(rnystrom): Set content-type based on asset type. |
- return request.response.addStream(stream).then((_) { |
+ return Chain.track(request.response.addStream(stream)).then((_) { |
// Log successful requests both so we can provide debugging |
// information and so scheduled_test knows we haven't timed out while |
// loading transformers. |
@@ -134,7 +134,7 @@ class BarbackServer { |
return; |
} |
- trace = new Trace.from(trace); |
+ trace = new Chain.forTrace(trace); |
_logRequest(request, "$error\n$trace"); |
// Otherwise, it's some internal error. |
@@ -145,7 +145,7 @@ class BarbackServer { |
}); |
}).catchError((error, trace) { |
if (error is! AssetNotFoundException) { |
- trace = new Trace.from(trace); |
+ trace = new Chain.forTrace(trace); |
_logRequest(request, "$error\n$trace"); |
_resultsController.addError(error, trace); |
@@ -161,7 +161,7 @@ class BarbackServer { |
/// Creates a web socket for [request] which should be an upgrade request. |
void _handleWebSocket(HttpRequest request) { |
- WebSocketTransformer.upgrade(request).then((socket) { |
+ Chain.track(WebSocketTransformer.upgrade(request)).then((socket) { |
socket.listen((data) { |
var command; |
try { |