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

Unified Diff: pkg/scheduled_test/lib/scheduled_server.dart

Issue 812253002: Delete a bunch of packages that are now on GitHub. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Un-delete http Created 6 years 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 | « pkg/scheduled_test/lib/scheduled_process.dart ('k') | pkg/scheduled_test/lib/scheduled_stream.dart » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: pkg/scheduled_test/lib/scheduled_server.dart
diff --git a/pkg/scheduled_test/lib/scheduled_server.dart b/pkg/scheduled_test/lib/scheduled_server.dart
deleted file mode 100644
index 2d9aba0ba5f5906eb1a95aa45b6f485062297ca8..0000000000000000000000000000000000000000
--- a/pkg/scheduled_test/lib/scheduled_server.dart
+++ /dev/null
@@ -1,106 +0,0 @@
-// Copyright (c) 2013, the Dart project authors. Please see the AUTHORS file
-// for details. All rights reserved. Use of this source code is governed by a
-// BSD-style license that can be found in the LICENSE file.
-
-library scheduled_test.scheduled_server;
-
-import 'dart:async';
-import 'dart:collection';
-import 'dart:io';
-
-import 'package:http_multi_server/http_multi_server.dart';
-import 'package:shelf/shelf.dart' as shelf;
-import 'package:shelf/shelf_io.dart' as shelf_io;
-
-import 'scheduled_test.dart';
-import 'src/scheduled_server/handler.dart';
-import 'src/utils.dart';
-
-/// A class representing an HTTP server that's scheduled to run in the course of
-/// the test. This class allows the server's request handling to be scheduled
-/// synchronously.
-///
-/// The server expects requests to be received in the order [handle] is called,
-/// and expects that no additional requests will be received.
-class ScheduledServer {
- /// The description of the server.
- final String description;
-
- /// The wrapped server.
- final Future<HttpServer> _server;
-
- /// The queue of handlers to run for upcoming requests. Each [Future] will
- /// complete once the schedule reaches the point where that handler was
- /// scheduled.
- final _handlers = new Queue<Handler>();
-
- /// The number of servers created. Used for auto-generating descriptions;
- static var _count = 0;
-
- ScheduledServer._(this._server, this.description);
-
- /// Creates a new server listening on an automatically-allocated port on
- /// localhost (both IPv4 and IPv6, if available).
- ///
- /// [description] is used to refer to the server in debugging messages.
- factory ScheduledServer([String description]) {
- var id = _count++;
- if (description == null) description = 'scheduled server $id';
-
- var scheduledServer;
- scheduledServer = new ScheduledServer._(schedule(() {
- return HttpMultiServer.loopback(0).then((server) {
- shelf_io.serveRequests(server, scheduledServer._handleRequest);
- currentSchedule.onComplete.schedule(() => server.close(force: true));
- return server;
- });
- }, "starting '$description'"), description);
- return scheduledServer;
- }
-
- /// The port on which the server is listening.
- Future<int> get port => _server.then((s) => s.port);
-
- /// The base URL of the server, including its port.
- Future<Uri> get url => port.then((p) => Uri.parse("http://localhost:$p"));
-
- /// Schedules [handler] to handle a request to the server with [method] and
- /// [path]. The schedule will wait until an HTTP request is received. If that
- /// request doesn't have the expected [method] and [path], it will fail.
- /// Otherwise, it will run [fn]. If [fn] returns a [Future], the schedule will
- /// wait until that [Future] completes.
- ///
- /// The request must be received at the point in the schedule at which
- /// [handle] was called, or in the task immediately prior (to allow for
- /// non-deterministic asynchronicity). Otherwise, an error will be thrown.
- void handle(String method, String path, shelf.Handler fn) {
- var handler = new Handler(this, method, path, fn);
- _handlers.add(handler);
- schedule(() {
- handler.ready = true;
- return handler.result;
- }, "'$description' waiting for $method $path");
- }
-
- /// The handler for incoming [shelf.Request]s to this server.
- ///
- /// This dispatches the request to the first handler in the queue. It's that
- /// handler's responsibility to check that the method/path are correct and
- /// that it's being run at the correct time.
- Future<shelf.Response> _handleRequest(shelf.Request request) {
- return wrapFuture(syncFuture(() {
- if (_handlers.isEmpty) {
- fail("'$description' received ${request.method} ${request.url.path} "
- "when no more requests were expected.");
- }
- return _handlers.removeFirst().fn(request);
- }), 'receiving ${request.method} ${request.url.path}').catchError((error) {
- // Don't let errors bubble up to the shelf handler. It will print them to
- // stderr, but the user will already be notified via the scheduled_test
- // infrastructure.
- return new shelf.Response.internalServerError(
- body: error.toString(),
- headers: {'content-type': 'text/plain'});
- });
- }
-}
« no previous file with comments | « pkg/scheduled_test/lib/scheduled_process.dart ('k') | pkg/scheduled_test/lib/scheduled_stream.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698