Implement list based output stream and add pipe to list based input streams

tests/standalone/src/ListInputStreamTest.dart

 // Copyright (c) 2011, 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.
 
 void testEmptyListInputStream() {
   InputStream stream = new ListInputStream([]);
   ReceivePort donePort = new ReceivePort();
 
   void onData() {
-    throw "On data expected";
+    throw "No data expected";
   }
 
   void onClose() {
     donePort.toSendPort().send(null);
   }
 
   stream.dataHandler = onData;
   stream.closeHandler = onClose;
 
   donePort.receive((x,y) => donePort.close());
 }
 
 void testEmptyDynamicListInputStream() {
   InputStream stream = new DynamicListInputStream();
   ReceivePort donePort = new ReceivePort();
 
   void onData() {
-    throw "On data expected";
+    throw "No data expected";
   }
 
   void onClose() {
     donePort.toSendPort().send(null);
   }
 
   stream.dataHandler = onData;
   stream.closeHandler = onClose;
   stream.markEndOfStream();
 
@@ skipping 41 matching lines @@
     Expect.equals(data.length, count);
     donePort.toSendPort().send(count);
   }
 
   stream.dataHandler = onData;
   stream.closeHandler = onClose;
 
   donePort.receive((x,y) => donePort.close());
 }
 
+void testListInputStreamPipe1() {
+  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
+  InputStream input = new ListInputStream(data);
+  OutputStream output = new ListOutputStream();
+  ReceivePort donePort = new ReceivePort();
+
+  void onClose() {
+    var contents = output.contents();
+    Expect.equals(data.length, contents.length);
+    donePort.toSendPort().send(null);
+  }
+
+  input.closeHandler = onClose;
+  input.pipe(output);
+
+  donePort.receive((x,y) => donePort.close());
+}
+
+void testListInputStreamPipe2() {
+  List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
+  OutputStream output = new ListOutputStream();
+  ReceivePort donePort = new ReceivePort();
+  int count = 0;
+
+  void onClose() {
+    if (count < 10) {
+      InputStream input = new ListInputStream(data);
+      input.closeHandler = onClose;
+      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);
+    }
+  }
+
+  InputStream input = new ListInputStream(data);
+  input.closeHandler = onClose;
+  input.pipe(output, close: false);
+  count++;
+
+  donePort.receive((x,y) => donePort.close());
+}
+
 void testDynamicListInputStream1() {
   List<int> data = [0x00, 0x01, 0x10, 0x11, 0x7e, 0x7f, 0x80, 0x81, 0xfe, 0xff];
   InputStream stream = new DynamicListInputStream();
   int count = 0;
   ReceivePort donePort = new ReceivePort();
 
   void onData() {
     List<int> x = stream.read(1);
     Expect.equals(1, x.length);
     x = stream.read();
@@ skipping 16 matching lines @@
   stream.closeHandler = onClose;
 
   donePort.receive((x,y) => donePort.close());
 }
 
 main() {
   testEmptyListInputStream();
   testEmptyDynamicListInputStream();
   testListInputStream1();
   testListInputStream2();
+  testListInputStreamPipe1();
+  testListInputStreamPipe2();
   testDynamicListInputStream1();
 }