| Index: tests/standalone/src/io/ListInputStreamTest.dart
|
| diff --git a/tests/standalone/src/io/ListInputStreamTest.dart b/tests/standalone/src/io/ListInputStreamTest.dart
|
| deleted file mode 100644
|
| index b4aa435c6884c14813ef95e603159ef4c209cd53..0000000000000000000000000000000000000000
|
| --- a/tests/standalone/src/io/ListInputStreamTest.dart
|
| +++ /dev/null
|
| @@ -1,291 +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:io");
|
| -#import("dart:isolate");
|
| -
|
| -void testEmptyListInputStream() {
|
| - ListInputStream stream = new ListInputStream();
|
| - stream.write([]);
|
| - stream.markEndOfStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - throw "No data expected";
|
| - }
|
| -
|
| - void onClosed() {
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testEmptyDynamicListInputStream() {
|
| - ListInputStream stream = new ListInputStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - throw "No data expected";
|
| - }
|
| -
|
| - void onClosed() {
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| - stream.markEndOfStream();
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputStream1() {
|
| - List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
|
| - ListInputStream stream = new ListInputStream();
|
| - stream.write(data);
|
| - stream.markEndOfStream();
|
| - int count = 0;
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - List<int> x = stream.read(1);
|
| - Expect.equals(1, x.length);
|
| - Expect.equals(data[count++], x[0]);
|
| - }
|
| -
|
| - void onClosed() {
|
| - Expect.equals(data.length, count);
|
| - donePort.toSendPort().send(count);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputStream2() {
|
| - List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
|
| - ListInputStream stream = new ListInputStream();
|
| - stream.write(data);
|
| - stream.markEndOfStream();
|
| - int count = 0;
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - List<int> x = new List<int>(2);
|
| - var bytesRead = stream.readInto(x);
|
| - Expect.equals(2, bytesRead);
|
| - Expect.equals(data[count++], x[0]);
|
| - Expect.equals(data[count++], x[1]);
|
| - }
|
| -
|
| - void onClosed() {
|
| - Expect.equals(data.length, count);
|
| - donePort.toSendPort().send(count);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputStreamPipe1() {
|
| - List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
|
| - ListInputStream input = new ListInputStream();
|
| - input.write(data);
|
| - input.markEndOfStream();
|
| - ListOutputStream output = new ListOutputStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onClosed() {
|
| - var contents = output.contents();
|
| - Expect.equals(data.length, contents.length);
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - input.onClosed = onClosed;
|
| - input.pipe(output);
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputStreamPipe2() {
|
| - List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
|
| - ListOutputStream output = new ListOutputStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| - int count = 0;
|
| -
|
| - void onClosed() {
|
| - if (count < 10) {
|
| - ListInputStream input = new ListInputStream();
|
| - input.write(data);
|
| - input.markEndOfStream();
|
| - input.onClosed = onClosed;
|
| - if (count < 9) {
|
| - input.pipe(output, close: false);
|
| - } else {
|
| - input.pipe(output);
|
| - }
|
| - count++;
|
| - } else {
|
| - var contents = output.contents();
|
| - Expect.equals(data.length * 10, contents.length);
|
| - donePort.toSendPort().send(null);
|
| - }
|
| - }
|
| -
|
| - ListInputStream input = new ListInputStream();
|
| - input.write(data);
|
| - input.markEndOfStream();
|
| - input.onClosed = onClosed;
|
| - input.pipe(output, close: false);
|
| - count++;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputClose1() {
|
| - List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
|
| - ListInputStream stream = new ListInputStream();
|
| - stream.write(data);
|
| - stream.markEndOfStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - throw "No data expected";
|
| - }
|
| -
|
| - void onClosed() {
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| - stream.close();
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testListInputClose2() {
|
| - List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
|
| - ListInputStream stream = new ListInputStream();
|
| - stream.write(data);
|
| - stream.markEndOfStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| - int count = 0;
|
| -
|
| - void onData() {
|
| - count += stream.read(2).length;
|
| - stream.close();
|
| - }
|
| -
|
| - void onClosed() {
|
| - Expect.equals(2, count);
|
| - donePort.toSendPort().send(count);
|
| - }
|
| -
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testDynamicListInputStream() {
|
| - List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
|
| - ListInputStream stream = new ListInputStream();
|
| - int count = 0;
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - List<int> x = stream.read(1);
|
| - Expect.equals(1, x.length);
|
| - x = stream.read();
|
| - Expect.equals(9, x.length);
|
| - count++;
|
| - if (count < 10) {
|
| - stream.write(data);
|
| - } else {
|
| - stream.markEndOfStream();
|
| - }
|
| - }
|
| -
|
| - void onClosed() {
|
| - Expect.equals(data.length, count);
|
| - donePort.toSendPort().send(count);
|
| - }
|
| -
|
| - stream.write(data);
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testDynamicListInputClose1() {
|
| - List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
|
| - ListInputStream stream = new ListInputStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| -
|
| - void onData() {
|
| - throw "No data expected";
|
| - }
|
| -
|
| - void onClosed() {
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - stream.write(data);
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| - stream.close();
|
| - Expect.throws(() => stream.write(data), (e) => e is StreamException);
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -void testDynamicListInputClose2() {
|
| - List<int> data = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9];
|
| - ListInputStream stream = new ListInputStream();
|
| - ReceivePort donePort = new ReceivePort();
|
| - int count = 0;
|
| -
|
| - void onData() {
|
| - count += stream.read(15).length;
|
| - stream.close();
|
| - Expect.throws(() => stream.write(data), (e) => e is StreamException);
|
| - }
|
| -
|
| - void onClosed() {
|
| - Expect.equals(15, count);
|
| - donePort.toSendPort().send(null);
|
| - }
|
| -
|
| - stream.write(data);
|
| - stream.write(data);
|
| - stream.write(data);
|
| - stream.onData = onData;
|
| - stream.onClosed = onClosed;
|
| -
|
| - donePort.receive((x,y) => donePort.close());
|
| -}
|
| -
|
| -main() {
|
| - testEmptyListInputStream();
|
| - testEmptyDynamicListInputStream();
|
| - testListInputStream1();
|
| - testListInputStream2();
|
| - testListInputStreamPipe1();
|
| - testListInputStreamPipe2();
|
| - testListInputClose1();
|
| - testListInputClose2();
|
| - testDynamicListInputStream();
|
| - testDynamicListInputClose1();
|
| - testDynamicListInputClose2();
|
| -}
|
|
|