OLD | NEW |
| (Empty) |
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 | |
3 // BSD-style license that can be found in the LICENSE file. | |
4 | |
5 #import("dart:io"); | |
6 #import("dart:isolate"); | |
7 | |
8 void testEmptyListOutputStream1() { | |
9 ListOutputStream stream = new ListOutputStream(); | |
10 Expect.equals(null, stream.contents()); | |
11 stream.close(); | |
12 Expect.equals(null, stream.contents()); | |
13 Expect.throws(() { stream.write([0]); }); | |
14 } | |
15 | |
16 | |
17 void testEmptyListOutputStream2() { | |
18 ListOutputStream stream = new ListOutputStream(); | |
19 ReceivePort donePort = new ReceivePort(); | |
20 | |
21 void onNoPendingWrites() { | |
22 stream.close(); | |
23 } | |
24 | |
25 void onClosed() { | |
26 Expect.equals(null, stream.contents()); | |
27 donePort.toSendPort().send(null); | |
28 } | |
29 | |
30 stream.onNoPendingWrites = onNoPendingWrites; | |
31 stream.onClosed = onClosed; | |
32 | |
33 donePort.receive((x,y) => donePort.close()); | |
34 } | |
35 | |
36 | |
37 void testListOutputStream1() { | |
38 ListOutputStream stream = new ListOutputStream(); | |
39 Expect.equals(null, stream.contents()); | |
40 stream.write([1, 2]); | |
41 stream.writeFrom([1, 2, 3, 4, 5], 2, 2); | |
42 stream.write([5]); | |
43 stream.close(); | |
44 var contents = stream.contents(); | |
45 Expect.equals(5, contents.length); | |
46 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); | |
47 Expect.equals(null, stream.contents()); | |
48 } | |
49 | |
50 | |
51 void testListOutputStream2() { | |
52 ListOutputStream stream = new ListOutputStream(); | |
53 ReceivePort donePort = new ReceivePort(); | |
54 int stage = 0; | |
55 void onNoPendingWrites() { | |
56 switch (stage) { | |
57 case 0: | |
58 stream.write([1, 2]); | |
59 break; | |
60 case 1: | |
61 stream.writeFrom([1, 2, 3, 4, 5], 2, 2); | |
62 break; | |
63 case 2: | |
64 stream.write([5]); | |
65 break; | |
66 case 3: | |
67 stream.close(); | |
68 break; | |
69 } | |
70 stage++; | |
71 } | |
72 | |
73 void onClosed() { | |
74 Expect.equals(4, stage); | |
75 var contents = stream.contents(); | |
76 Expect.equals(5, contents.length); | |
77 for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); | |
78 Expect.equals(null, stream.contents()); | |
79 donePort.toSendPort().send(null); | |
80 } | |
81 | |
82 stream.onNoPendingWrites = onNoPendingWrites; | |
83 stream.onClosed = onClosed; | |
84 | |
85 donePort.receive((x,y) => donePort.close()); | |
86 } | |
87 | |
88 void testListOutputStream3() { | |
89 ListOutputStream stream = new ListOutputStream(); | |
90 ReceivePort donePort = new ReceivePort(); | |
91 void onNoPendingWrites() { | |
92 stream.writeString("abcdABCD"); | |
93 stream.writeString("abcdABCD", Encoding.UTF_8); | |
94 stream.writeString("abcdABCD", Encoding.ISO_8859_1); | |
95 stream.writeString("abcdABCD", Encoding.ASCII); | |
96 stream.writeString("æøå", Encoding.UTF_8); | |
97 stream.close(); | |
98 } | |
99 | |
100 void onClosed() { | |
101 var contents = stream.contents(); | |
102 Expect.equals(38, contents.length); | |
103 donePort.toSendPort().send(null); | |
104 } | |
105 | |
106 stream.onNoPendingWrites = onNoPendingWrites; | |
107 stream.onClosed = onClosed; | |
108 | |
109 donePort.receive((x,y) => donePort.close()); | |
110 } | |
111 | |
112 main() { | |
113 testEmptyListOutputStream1(); | |
114 testEmptyListOutputStream2(); | |
115 testListOutputStream1(); | |
116 testListOutputStream2(); | |
117 testListOutputStream3(); | |
118 } | |
OLD | NEW |