Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(2794)

Unified Diff: lib/shelf_io.dart

Issue 837193005: pkg/shelf: formatted code (Closed) Base URL: https://github.com/dart-lang/shelf.git@master
Patch Set: nits Created 5 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « example/example_server.dart ('k') | lib/src/cascade.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: lib/shelf_io.dart
diff --git a/lib/shelf_io.dart b/lib/shelf_io.dart
index 878935f0a188a40d2a8df8675253414534ca2dda..4ca48b6866481402cb7fd5ea118f19700a52934a 100644
--- a/lib/shelf_io.dart
+++ b/lib/shelf_io.dart
@@ -23,8 +23,7 @@ import 'src/util.dart';
///
/// See the documentation for [HttpServer.bind] for more details on [address],
/// [port], and [backlog].
-Future<HttpServer> serve(Handler handler, address, int port,
- {int backlog}) {
+Future<HttpServer> serve(Handler handler, address, int port, {int backlog}) {
if (backlog == null) backlog = 0;
return HttpServer.bind(address, port, backlog: backlog).then((server) {
serveRequests(server, handler);
@@ -81,11 +80,11 @@ Future handleRequest(HttpRequest request, Handler handler) {
response = _logError('null response from handler.');
} else if (!shelfRequest.canHijack) {
var message = new StringBuffer()
- ..writeln("Got a response for hijacked request "
- "${shelfRequest.method} ${shelfRequest.requestedUri}:")
- ..writeln(response.statusCode);
- response.headers.forEach((key, value) =>
- message.writeln("${key}: ${value}"));
+ ..writeln("Got a response for hijacked request "
+ "${shelfRequest.method} ${shelfRequest.requestedUri}:")
+ ..writeln(response.statusCode);
+ response.headers
+ .forEach((key, value) => message.writeln("${key}: ${value}"));
throw new Exception(message.toString().trim());
}
@@ -106,13 +105,16 @@ Request _fromHttpRequest(HttpRequest request) {
});
onHijack(callback) {
- return request.response.detachSocket(writeHeaders: false)
+ return request.response
+ .detachSocket(writeHeaders: false)
.then((socket) => callback(socket, socket));
}
return new Request(request.method, request.requestedUri,
- protocolVersion: request.protocolVersion, headers: headers,
- body: request, onHijack: onHijack);
+ protocolVersion: request.protocolVersion,
+ headers: headers,
+ body: request,
+ onHijack: onHijack);
}
Future _writeResponse(Response response, HttpResponse httpResponse) {
@@ -131,7 +133,8 @@ Future _writeResponse(Response response, HttpResponse httpResponse) {
httpResponse.headers.date = new DateTime.now().toUtc();
}
- return httpResponse.addStream(response.read())
+ return httpResponse
+ .addStream(response.read())
.then((_) => httpResponse.close());
}
@@ -143,8 +146,7 @@ Response _logError(String message, [StackTrace stackTrace]) {
chain = new Chain.forTrace(stackTrace);
}
chain = chain
- .foldFrames((frame) => frame.isCore || frame.package == 'shelf')
- .terse;
+ .foldFrames((frame) => frame.isCore || frame.package == 'shelf').terse;
stderr.writeln('ERROR - ${new DateTime.now()}');
stderr.writeln(message);
« no previous file with comments | « example/example_server.dart ('k') | lib/src/cascade.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698