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

Unified Diff: pkg/pool/test/pool_test.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/pool/pubspec.yaml ('k') | pkg/scheduled_test/CHANGELOG.md » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: pkg/pool/test/pool_test.dart
diff --git a/pkg/pool/test/pool_test.dart b/pkg/pool/test/pool_test.dart
deleted file mode 100644
index bfeb876b19efaf6f259cc2c33228f6ff76b6d78e..0000000000000000000000000000000000000000
--- a/pkg/pool/test/pool_test.dart
+++ /dev/null
@@ -1,138 +0,0 @@
-// Copyright (c) 2014, 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.
-
-import 'dart:async';
-
-import 'package:pool/pool.dart';
-import 'package:stack_trace/stack_trace.dart';
-import 'package:unittest/unittest.dart';
-
-void main() {
- group("request()", () {
- test("resources can be requested freely up to the limit", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 50; i++) {
- expect(pool.request(), completes);
- }
- });
-
- test("resources block past the limit", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 50; i++) {
- expect(pool.request(), completes);
- }
- expect(pool.request(), doesNotComplete);
- });
-
- test("a blocked resource is allocated when another is released", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 49; i++) {
- expect(pool.request(), completes);
- }
-
- return pool.request().then((lastAllocatedResource) {
- var blockedResource = pool.request();
-
- return pumpEventQueue().then((_) {
- lastAllocatedResource.release();
- return pumpEventQueue();
- }).then((_) {
- expect(blockedResource, completes);
- });
- });
- });
- });
-
- group("withResource()", () {
- test("can be called freely up to the limit", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 50; i++) {
- pool.withResource(expectAsync(() => new Completer().future));
- }
- });
-
- test("blocks the callback past the limit", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 50; i++) {
- pool.withResource(expectAsync(() => new Completer().future));
- }
- pool.withResource(expectNoAsync());
- });
-
- test("a blocked resource is allocated when another is released", () {
- var pool = new Pool(50);
- var requests = [];
- for (var i = 0; i < 49; i++) {
- pool.withResource(expectAsync(() => new Completer().future));
- }
-
- var completer = new Completer();
- var lastAllocatedResource = pool.withResource(() => completer.future);
- var blockedResourceAllocated = false;
- var blockedResource = pool.withResource(() {
- blockedResourceAllocated = true;
- });
-
- return pumpEventQueue().then((_) {
- expect(blockedResourceAllocated, isFalse);
- completer.complete();
- return pumpEventQueue();
- }).then((_) {
- expect(blockedResourceAllocated, isTrue);
- });
- });
- });
-
- // TODO(nweiz): Test timeouts when it's easier to use third-party packages.
- // See r38552.
-}
-
-/// Returns a [Future] that completes after pumping the event queue [times]
-/// times. By default, this should pump the event queue enough times to allow
-/// any code to run, as long as it's not waiting on some external event.
-Future pumpEventQueue([int times = 20]) {
- if (times == 0) return new Future.value();
- // We use a delayed future to allow microtask events to finish. The
- // Future.value or Future() constructors use scheduleMicrotask themselves and
- // would therefore not wait for microtask callbacks that are scheduled after
- // invoking this method.
- return new Future.delayed(Duration.ZERO, () => pumpEventQueue(times - 1));
-}
-
-/// Returns a function that will cause the test to fail if it's called.
-///
-/// This won't let the test complete until it's confident that the function
-/// won't be called.
-Function expectNoAsync() {
- // Make sure the test lasts long enough for the function to get called if it's
- // going to get called.
- expect(pumpEventQueue(), completes);
-
- var stack = new Trace.current(1);
- return () => handleExternalError(
- new TestFailure("Expected function not to be called."), "",
- stack);
-}
-
-/// A matcher for Futures that asserts that they don't complete.
-///
-/// This won't let the test complete until it's confident that the function
-/// won't be called.
-Matcher get doesNotComplete => predicate((future) {
- expect(future, new isInstanceOf<Future>('Future'));
- // Make sure the test lasts long enough for the function to get called if it's
- // going to get called.
- expect(pumpEventQueue(), completes);
-
- var stack = new Trace.current(1);
- future.then((_) => handleExternalError(
- new TestFailure("Expected future not to complete."), "",
- stack));
- return true;
-});
« no previous file with comments | « pkg/pool/pubspec.yaml ('k') | pkg/scheduled_test/CHANGELOG.md » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698