Update mime_multipart_parser to be a StreamTransformer, public available.

tests/standalone/io/mime_multipart_parser_test.dart

 // Copyright (c) 2013, 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 "package:expect/expect.dart";
 import 'dart:async';
 import 'dart:math';
-
-part '../../../sdk/lib/io/io_sink.dart';
-part "../../../sdk/lib/io/http.dart";
-part "../../../sdk/lib/io/http_impl.dart";
-part "../../../sdk/lib/io/http_parser.dart";
-part "../../../sdk/lib/io/mime_multipart_parser.dart";
-part '../../../sdk/lib/io/socket.dart';
+import 'dart:io';
+import 'dart:isolate';
 
 void testParse(String message,
                String boundary,
                [List<Map> expectedHeaders,
-               List expectedParts]) {
-  _MimeMultipartParser parser;
-  int partCount;
-  Map headers;
-  List<int> currentPart;
-  bool lastPartCalled;
+               List expectedParts,
+               bool expectError = false]) {
+  void testWrite(List<int> data, [int chunkSize = -1]) {
+    StreamController controller = new StreamController();
 
-  void reset() {
-    parser = new _MimeMultipartParser(boundary);
-    parser.partStart = (f, v) {
-    };
-    parser.headerReceived = (f, v) {
-      headers[f] = v;
-    };
-    parser.headersComplete = () {
+    var stream = controller.stream.transform(
+        new MimeMultipartTransformer(boundary));
+    int i = 0;
+    var port = new ReceivePort();
+    stream.listen((multipart) {
+      int part = i++;
       if (expectedHeaders != null) {
-        expectedHeaders[partCount].forEach(
-            (String name, String value) {
-              Expect.equals(value, headers[name]);
-            });
+        Expect.mapEquals(expectedHeaders[part], multipart.headers);
       }
-    };
-    parser.partDataReceived = (List<int> data) {
-      if (currentPart == null) currentPart = new List<int>();
-      currentPart.addAll(data);
-    };
-    parser.partEnd = (lastPart) {
-      Expect.isFalse(lastPartCalled);
-      lastPartCalled = lastPart;
-      if (expectedParts[partCount] != null) {
-        List<int> expectedPart;
-        if (expectedParts[partCount] is String) {
-          expectedPart = expectedParts[partCount].codeUnits;
-        } else {
-          expectedPart = expectedParts[partCount];
-        }
-        Expect.listEquals(expectedPart, currentPart);
+      var partPort = new ReceivePort();
+      multipart.fold([], (buffer, data) => buffer..addAll(data))
+          .then((data) {
+            if (expectedParts[part] != null) {
+              Expect.listEquals(expectedParts[part].codeUnits, data);
+            }
+            partPort.close();
+          });
+    }, onError: (error) {
+      if (!expectError) throw error;
+    }, onDone: () {
+      if (expectedParts != null) {
+        Expect.equals(expectedParts.length, i);
       }
-      currentPart = null;
-      partCount++;
-      if (lastPart) Expect.equals(expectedParts.length, partCount);
-    };
+      port.close();
+    });
 
-    partCount = 0;
-    headers = new Map();
-    currentPart = null;
-    lastPartCalled = false;
-  }
+    if (chunkSize == -1) chunkSize = data.length;
 
-  void testWrite(List<int> data, [int chunkSize = -1]) {
-    if (chunkSize == -1) chunkSize = data.length;
-    reset();
     int written = 0;
     for (int pos = 0; pos < data.length; pos += chunkSize) {
       int remaining = data.length - pos;
       int writeLength = min(chunkSize, remaining);
-      int parsed =
-          parser.update(data.sublist(pos, pos + writeLength), 0, writeLength);
-      Expect.equals(writeLength, parsed);
+      controller.add(data.sublist(pos, pos + writeLength));
       written += writeLength;
     }
-    Expect.isTrue(lastPartCalled);
+    controller.close();
   }
 
   // Test parsing the data three times delivering the data in
   // different chunks.
   List<int> data = message.codeUnits;
   testWrite(data);
   testWrite(data, 10);
   testWrite(data, 2);
   testWrite(data, 1);
 }
@@ skipping 223 matching lines @@
   message = """
 --xxx\r
 \r
 \r
 Body 1\r
 --xxx\r
 \r
 \r
 Body2\r
 --xxx--\r\n""";
-  Expect.throws(() => testParse(message, "xxx", null, [null, null]));
+  testParse(message, "xxx", null, ["\r\nBody2"]);
 
   // Missing end boundary.
   message = """
 \r
 --xxx\r
 \r
 \r
 Body 1\r
 --xxx\r
 \r
 \r
 Body2\r
 --xxx\r\n""";
-  Expect.throws(() => testParse(message, "xxx", null, [null, null]));
+  testParse(message, "xxx", null, [null, null], true);
 }
 
 void main() {
   testParseValid();
   testParseInvalid();
 }