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

Side by Side Diff: tests/standalone/src/ListOutputStreamTest.dart

Issue 9500002: Rename blahHandler to onBlah throughout dart:io. (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Address comments. Created 8 years, 9 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) 2011, 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:io"); 5 #import("dart:io");
6 #import("dart:isolate"); 6 #import("dart:isolate");
7 7
8 void testEmptyListOutputStream1() { 8 void testEmptyListOutputStream1() {
9 OutputStream stream = new ListOutputStream(); 9 OutputStream stream = new ListOutputStream();
10 Expect.equals(null, stream.contents()); 10 Expect.equals(null, stream.contents());
11 stream.close(); 11 stream.close();
12 Expect.equals(null, stream.contents()); 12 Expect.equals(null, stream.contents());
13 Expect.throws(() { stream.write([0]); }); 13 Expect.throws(() { stream.write([0]); });
14 } 14 }
15 15
16 16
17 void testEmptyListOutputStream2() { 17 void testEmptyListOutputStream2() {
18 OutputStream stream = new ListOutputStream(); 18 OutputStream stream = new ListOutputStream();
19 ReceivePort donePort = new ReceivePort(); 19 ReceivePort donePort = new ReceivePort();
20 20
21 void onNoPendingWrite() { 21 void onNoPendingWrites() {
22 stream.close(); 22 stream.close();
23 } 23 }
24 24
25 void onClose() { 25 void onClosed() {
26 Expect.equals(null, stream.contents()); 26 Expect.equals(null, stream.contents());
27 donePort.toSendPort().send(null); 27 donePort.toSendPort().send(null);
28 } 28 }
29 29
30 stream.noPendingWriteHandler = onNoPendingWrite; 30 stream.onNoPendingWrites = onNoPendingWrites;
31 stream.closeHandler = onClose; 31 stream.onClosed = onClosed;
32 32
33 donePort.receive((x,y) => donePort.close()); 33 donePort.receive((x,y) => donePort.close());
34 } 34 }
35 35
36 36
37 void testListOutputStream1() { 37 void testListOutputStream1() {
38 OutputStream stream = new ListOutputStream(); 38 OutputStream stream = new ListOutputStream();
39 Expect.equals(null, stream.contents()); 39 Expect.equals(null, stream.contents());
40 stream.write([1, 2]); 40 stream.write([1, 2]);
41 stream.writeFrom([1, 2, 3, 4, 5], 2, 2); 41 stream.writeFrom([1, 2, 3, 4, 5], 2, 2);
42 stream.write([5]); 42 stream.write([5]);
43 stream.close(); 43 stream.close();
44 var contents = stream.contents(); 44 var contents = stream.contents();
45 Expect.equals(5, contents.length); 45 Expect.equals(5, contents.length);
46 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); 46 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]);
47 Expect.equals(null, stream.contents()); 47 Expect.equals(null, stream.contents());
48 } 48 }
49 49
50 50
51 void testListOutputStream2() { 51 void testListOutputStream2() {
52 OutputStream stream = new ListOutputStream(); 52 OutputStream stream = new ListOutputStream();
53 ReceivePort donePort = new ReceivePort(); 53 ReceivePort donePort = new ReceivePort();
54 int stage = 0; 54 int stage = 0;
55 void onNoPendingWrite() { 55 void onNoPendingWrites() {
56 switch (stage) { 56 switch (stage) {
57 case 0: 57 case 0:
58 stream.write([1, 2]); 58 stream.write([1, 2]);
59 break; 59 break;
60 case 1: 60 case 1:
61 stream.writeFrom([1, 2, 3, 4, 5], 2, 2); 61 stream.writeFrom([1, 2, 3, 4, 5], 2, 2);
62 break; 62 break;
63 case 2: 63 case 2:
64 stream.write([5]); 64 stream.write([5]);
65 break; 65 break;
66 case 3: 66 case 3:
67 stream.close(); 67 stream.close();
68 break; 68 break;
69 } 69 }
70 stage++; 70 stage++;
71 } 71 }
72 72
73 void onClose() { 73 void onClosed() {
74 Expect.equals(4, stage); 74 Expect.equals(4, stage);
75 var contents = stream.contents(); 75 var contents = stream.contents();
76 Expect.equals(5, contents.length); 76 Expect.equals(5, contents.length);
77 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); 77 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]);
78 Expect.equals(null, stream.contents()); 78 Expect.equals(null, stream.contents());
79 donePort.toSendPort().send(null); 79 donePort.toSendPort().send(null);
80 } 80 }
81 81
82 stream.noPendingWriteHandler = onNoPendingWrite; 82 stream.onNoPendingWrites = onNoPendingWrites;
83 stream.closeHandler = onClose; 83 stream.onClosed = onClosed;
84 84
85 donePort.receive((x,y) => donePort.close()); 85 donePort.receive((x,y) => donePort.close());
86 } 86 }
87 87
88 main() { 88 main() {
89 testEmptyListOutputStream1(); 89 testEmptyListOutputStream1();
90 testEmptyListOutputStream2(); 90 testEmptyListOutputStream2();
91 testListOutputStream1(); 91 testListOutputStream1();
92 testListOutputStream2(); 92 testListOutputStream2();
93 } 93 }
OLDNEW
« no previous file with comments | « tests/standalone/src/ListInputStreamTest.dart ('k') | tests/standalone/src/ProcessBrokenPipeTest.dart » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698