Merge IO v2 branch to bleeding edge

tests/standalone/io/list_input_stream_test.dart

Index: tests/standalone/io/list_input_stream_test.dart
diff --git a/tests/standalone/io/list_input_stream_test.dart b/tests/standalone/io/list_input_stream_test.dart
deleted file mode 100644
index cebf50d9f9d4448ff169f93cef8cdcb10f558946..0000000000000000000000000000000000000000
--- a/tests/standalone/io/list_input_stream_test.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>.fixedLength(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.read();
-    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.read();
-      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();
-}