Index: tests/standalone/io/list_output_stream_test.dart |
diff --git a/tests/standalone/io/list_output_stream_test.dart b/tests/standalone/io/list_output_stream_test.dart |
deleted file mode 100644 |
index ad3b0293b32f85a6ae047a2ab3e6c02cde05a578..0000000000000000000000000000000000000000 |
--- a/tests/standalone/io/list_output_stream_test.dart |
+++ /dev/null |
@@ -1,173 +0,0 @@ |
-// Copyright (c) 2012, 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 'dart:io'; |
-import 'dart:isolate'; |
- |
-void testEmptyListOutputStream1() { |
- ListOutputStream stream = new ListOutputStream(); |
- Expect.equals(null, stream.read()); |
- stream.close(); |
- Expect.equals(null, stream.read()); |
- Expect.throws(() { stream.write([0]); }); |
-} |
- |
- |
-void testEmptyListOutputStream2() { |
- ListOutputStream stream = new ListOutputStream(); |
- ReceivePort donePort = new ReceivePort(); |
- |
- void onNoPendingWrites() { |
- stream.close(); |
- } |
- |
- void onClosed() { |
- Expect.equals(null, stream.read()); |
- donePort.toSendPort().send(null); |
- } |
- |
- stream.onNoPendingWrites = onNoPendingWrites; |
- stream.onClosed = onClosed; |
- |
- donePort.receive((x,y) => donePort.close()); |
-} |
- |
- |
-void testListOutputStream1() { |
- ListOutputStream stream = new ListOutputStream(); |
- Expect.equals(null, stream.read()); |
- stream.write([1, 2]); |
- stream.writeFrom([1, 2, 3, 4, 5], 2, 2); |
- stream.write([5]); |
- stream.close(); |
- var contents = stream.read(); |
- Expect.equals(5, contents.length); |
- for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); |
- Expect.equals(null, stream.read()); |
-} |
- |
- |
-void testListOutputStream2() { |
- ListOutputStream stream = new ListOutputStream(); |
- ReceivePort donePort = new ReceivePort(); |
- int stage = 0; |
- void onNoPendingWrites() { |
- switch (stage) { |
- case 0: |
- stream.write([1, 2]); |
- break; |
- case 1: |
- stream.writeFrom([1, 2, 3, 4, 5], 2, 2); |
- break; |
- case 2: |
- stream.write([5]); |
- break; |
- case 3: |
- stream.close(); |
- break; |
- } |
- stage++; |
- } |
- |
- void onClosed() { |
- Expect.equals(4, stage); |
- var contents = stream.read(); |
- Expect.equals(5, contents.length); |
- for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); |
- Expect.equals(null, stream.read()); |
- donePort.toSendPort().send(null); |
- } |
- |
- stream.onNoPendingWrites = onNoPendingWrites; |
- stream.onClosed = onClosed; |
- |
- donePort.receive((x,y) => donePort.close()); |
-} |
- |
-void testListOutputStream3() { |
- ListOutputStream stream = new ListOutputStream(); |
- ReceivePort donePort = new ReceivePort(); |
- void onNoPendingWrites() { |
- stream.writeString("abcdABCD"); |
- stream.writeString("abcdABCD", Encoding.UTF_8); |
- stream.writeString("abcdABCD", Encoding.ISO_8859_1); |
- stream.writeString("abcdABCD", Encoding.ASCII); |
- stream.writeString("æøå", Encoding.UTF_8); |
- stream.close(); |
- } |
- |
- void onClosed() { |
- var contents = stream.read(); |
- Expect.equals(38, contents.length); |
- donePort.toSendPort().send(null); |
- } |
- |
- stream.onNoPendingWrites = onNoPendingWrites; |
- stream.onClosed = onClosed; |
- |
- donePort.receive((x,y) => donePort.close()); |
-} |
- |
-void testListOutputStream4() { |
- ListOutputStream stream = new ListOutputStream(); |
- ReceivePort donePort = new ReceivePort(); |
- List result = <int>[]; |
- |
- void onData() => result.addAll(stream.read()); |
- |
- void onClosed() { |
- Expect.equals(4, result.length); |
- for (var i = 0; i < result.length; i++) Expect.equals(i + 1, result[i]); |
- donePort.toSendPort().send(null); |
- } |
- |
- stream.onData = onData; |
- stream.onClosed = onClosed; |
- |
- Timer.run(() { |
- result.add(1); |
- stream.write([2]); |
- |
- Timer.run(() { |
- result.add(3); |
- stream.write([4]); |
- stream.close(); |
- }); |
- }); |
- |
- donePort.receive((x,y) => donePort.close()); |
-} |
- |
-void testListOutputStream5() { |
- ListOutputStream stream = new ListOutputStream(); |
- ReceivePort donePort = new ReceivePort(); |
- |
- stream.onClosed = () { |
- Expect.isTrue(stream.closed); |
- var contents = stream.read(); |
- Expect.equals(3, contents.length); |
- for (var i = 0; i < contents.length; i++) Expect.equals(i + 1, contents[i]); |
- donePort.toSendPort().send(null); |
- }; |
- |
- Expect.isFalse(stream.closed); |
- stream.write([1, 2, 3]); |
- Expect.isFalse(stream.closed); |
- stream.close(); |
- Expect.isTrue(stream.closed); |
- Expect.throws(() => stream.write([4, 5, 6])); |
- |
- donePort.receive((x,y) => donePort.close()); |
-} |
- |
-main() { |
- testEmptyListOutputStream1(); |
- testEmptyListOutputStream2(); |
- testListOutputStream1(); |
- testListOutputStream2(); |
- testListOutputStream3(); |
- testListOutputStream4(); |
- testListOutputStream5(); |
-} |