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

Unified Diff: packages/pool/test/pool_test.dart

Issue 3015713002: Roll to pickup pool changes
Patch Set: Created 3 years, 3 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 | « packages/pool/pubspec.yaml ('k') | packages/stack_trace/.travis.yml » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: packages/pool/test/pool_test.dart
diff --git a/packages/pool/test/pool_test.dart b/packages/pool/test/pool_test.dart
index 7fba9c0b06812470bc85befc890498a16f1e38d4..6feba75c34efd9691ab96fc43d69cffbb128b077 100644
--- a/packages/pool/test/pool_test.dart
+++ b/packages/pool/test/pool_test.dart
@@ -299,9 +299,11 @@ void main() {
test("pending requests are fulfilled", () async {
var pool = new Pool(1);
var resource1 = await pool.request();
- expect(pool.request().then((resource2) {
- resource2.release();
- }), completes);
+ expect(
+ pool.request().then((resource2) {
+ resource2.release();
+ }),
+ completes);
expect(pool.done, completes);
expect(pool.close(), completes);
resource1.release();
@@ -312,10 +314,12 @@ void main() {
var resource1 = await pool.request();
var completer = new Completer();
- expect(pool.request().then((resource2) {
- expect(completer.isCompleted, isTrue);
- resource2.release();
- }), completes);
+ expect(
+ pool.request().then((resource2) {
+ expect(completer.isCompleted, isTrue);
+ resource2.release();
+ }),
+ completes);
expect(pool.close(), completes);
resource1.allowRelease(() => completer.future);
@@ -333,11 +337,13 @@ void main() {
var resource1Released = false;
var resource2Released = false;
var resource3Released = false;
- expect(pool.close().then((_) {
- expect(resource1Released, isTrue);
- expect(resource2Released, isTrue);
- expect(resource3Released, isTrue);
- }), completes);
+ expect(
+ pool.close().then((_) {
+ expect(resource1Released, isTrue);
+ expect(resource2Released, isTrue);
+ expect(resource3Released, isTrue);
+ }),
+ completes);
resource1Released = true;
resource1.release();
@@ -360,9 +366,11 @@ void main() {
// [completer].
var completer = new Completer();
resource.allowRelease(() => completer.future);
- expect(pool.request().then((_) {
- expect(completer.isCompleted, isTrue);
- }), completes);
+ expect(
+ pool.request().then((_) {
+ expect(completer.isCompleted, isTrue);
+ }),
+ completes);
await new Future.delayed(Duration.ZERO);
pool.close();
@@ -381,10 +389,12 @@ void main() {
var completer2 = new Completer();
resource2.allowRelease(() => completer2.future);
- expect(pool.close().then((_) {
- expect(completer1.isCompleted, isTrue);
- expect(completer2.isCompleted, isTrue);
- }), completes);
+ expect(
+ pool.close().then((_) {
+ expect(completer1.isCompleted, isTrue);
+ expect(completer2.isCompleted, isTrue);
+ }),
+ completes);
await new Future.delayed(Duration.ZERO);
completer1.complete();
@@ -398,9 +408,11 @@ void main() {
var resource = await pool.request();
var completer = new Completer();
- expect(pool.close().then((_) {
- expect(completer.isCompleted, isTrue);
- }), completes);
+ expect(
+ pool.close().then((_) {
+ expect(completer.isCompleted, isTrue);
+ }),
+ completes);
await new Future.delayed(Duration.ZERO);
resource.allowRelease(() => completer.future);
@@ -438,10 +450,10 @@ Function expectNoAsync() {
///
/// This should only be called within a [FakeAsync.run] zone.
Matcher get doesNotComplete => predicate((future) {
- expect(future, new isInstanceOf<Future>());
+ expect(future, new isInstanceOf<Future>());
- var stack = new Trace.current(1);
- future.then((_) => registerException(
- new TestFailure("Expected future not to complete."), stack));
- return true;
-});
+ var stack = new Trace.current(1);
+ future.then((_) => registerException(
+ new TestFailure("Expected future not to complete."), stack));
+ return true;
+ });
« no previous file with comments | « packages/pool/pubspec.yaml ('k') | packages/stack_trace/.travis.yml » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698