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

Side by Side Diff: tests/lib/async/future_test.dart

Issue 11740027: Rename unsubscribe to cancel. (Closed) Base URL: https://dart.googlecode.com/svn/experimental/lib_v2/dart
Patch Set: Fix error message. Created 7 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 unified diff | Download patch | Annotate | Revision Log
OLDNEW
1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file 1 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file
2 // for details. All rights reserved. Use of this source code is governed by a 2 // for details. All rights reserved. Use of this source code is governed by a
3 // BSD-style license that can be found in the LICENSE file. 3 // BSD-style license that can be found in the LICENSE file.
4 4
5 import 'dart:async'; 5 import 'dart:async';
6 import 'dart:isolate'; 6 import 'dart:isolate';
7 7
8 testFutureAsStreamCompleteAfter() { 8 testFutureAsStreamCompleteAfter() {
9 var completer = new Completer(); 9 var completer = new Completer();
10 bool gotValue = false; 10 bool gotValue = false;
11 var port = new ReceivePort(); 11 var port = new ReceivePort();
12 completer.future.asStream().subscribe( 12 completer.future.asStream().listen(
13 onData: (data) { 13 (data) {
14 Expect.isFalse(gotValue); 14 Expect.isFalse(gotValue);
15 gotValue = true; 15 gotValue = true;
16 Expect.equals("value", data); 16 Expect.equals("value", data);
17 }, 17 },
18 onDone: () { 18 onDone: () {
19 Expect.isTrue(gotValue); 19 Expect.isTrue(gotValue);
20 port.close(); 20 port.close();
21 }); 21 });
22 completer.complete("value"); 22 completer.complete("value");
23 } 23 }
24 24
25 testFutureAsStreamCompleteBefore() { 25 testFutureAsStreamCompleteBefore() {
26 var completer = new Completer(); 26 var completer = new Completer();
27 bool gotValue = false; 27 bool gotValue = false;
28 var port = new ReceivePort(); 28 var port = new ReceivePort();
29 completer.complete("value"); 29 completer.complete("value");
30 completer.future.asStream().subscribe( 30 completer.future.asStream().listen(
31 onData: (data) { 31 (data) {
32 Expect.isFalse(gotValue); 32 Expect.isFalse(gotValue);
33 gotValue = true; 33 gotValue = true;
34 Expect.equals("value", data); 34 Expect.equals("value", data);
35 }, 35 },
36 onDone: () { 36 onDone: () {
37 Expect.isTrue(gotValue); 37 Expect.isTrue(gotValue);
38 port.close(); 38 port.close();
39 }); 39 });
40 } 40 }
41 41
42 testFutureAsStreamCompleteImmediate() { 42 testFutureAsStreamCompleteImmediate() {
43 bool gotValue = false; 43 bool gotValue = false;
44 var port = new ReceivePort(); 44 var port = new ReceivePort();
45 new Future.immediate("value").asStream().subscribe( 45 new Future.immediate("value").asStream().listen(
46 onData: (data) { 46 (data) {
47 Expect.isFalse(gotValue); 47 Expect.isFalse(gotValue);
48 gotValue = true; 48 gotValue = true;
49 Expect.equals("value", data); 49 Expect.equals("value", data);
50 }, 50 },
51 onDone: () { 51 onDone: () {
52 Expect.isTrue(gotValue); 52 Expect.isTrue(gotValue);
53 port.close(); 53 port.close();
54 }); 54 });
55 } 55 }
56 56
57 testFutureAsStreamCompleteErrorAfter() { 57 testFutureAsStreamCompleteErrorAfter() {
58 var completer = new Completer(); 58 var completer = new Completer();
59 bool gotError = false; 59 bool gotError = false;
60 var port = new ReceivePort(); 60 var port = new ReceivePort();
61 completer.future.asStream().subscribe( 61 completer.future.asStream().listen(
62 onData: (data) { 62 (data) {
63 Expect.fail("Unexpected data"); 63 Expect.fail("Unexpected data");
64 }, 64 },
65 onError: (error) { 65 onError: (error) {
66 Expect.isFalse(gotError); 66 Expect.isFalse(gotError);
67 gotError = true; 67 gotError = true;
68 Expect.equals("error", error.error); 68 Expect.equals("error", error.error);
69 }, 69 },
70 onDone: () { 70 onDone: () {
71 Expect.isTrue(gotError); 71 Expect.isTrue(gotError);
72 port.close(); 72 port.close();
73 }); 73 });
74 completer.completeError("error"); 74 completer.completeError("error");
75 } 75 }
76 76
77 testFutureAsStreamWrapper() { 77 testFutureAsStreamWrapper() {
78 var completer = new Completer(); 78 var completer = new Completer();
79 bool gotValue = false; 79 bool gotValue = false;
80 var port = new ReceivePort(); 80 var port = new ReceivePort();
81 completer.complete("value"); 81 completer.complete("value");
82 completer.future 82 completer.future
83 .catchError((_) { throw "not possible"; }) // Returns a future wrapper. 83 .catchError((_) { throw "not possible"; }) // Returns a future wrapper.
84 .asStream().subscribe( 84 .asStream().listen(
85 onData: (data) { 85 (data) {
86 Expect.isFalse(gotValue); 86 Expect.isFalse(gotValue);
87 gotValue = true; 87 gotValue = true;
88 Expect.equals("value", data); 88 Expect.equals("value", data);
89 }, 89 },
90 onDone: () { 90 onDone: () {
91 Expect.isTrue(gotValue); 91 Expect.isTrue(gotValue);
92 port.close(); 92 port.close();
93 }); 93 });
94 } 94 }
95 95
96 main() { 96 main() {
97 testFutureAsStreamCompleteAfter(); 97 testFutureAsStreamCompleteAfter();
98 testFutureAsStreamCompleteBefore(); 98 testFutureAsStreamCompleteBefore();
99 testFutureAsStreamCompleteImmediate(); 99 testFutureAsStreamCompleteImmediate();
100 testFutureAsStreamCompleteErrorAfter(); 100 testFutureAsStreamCompleteErrorAfter();
101 testFutureAsStreamWrapper(); 101 testFutureAsStreamWrapper();
102 } 102 }
103 103
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698