Move dart2js entrypoint detection into isPrimary.

pkg/scheduled_test/test/scheduled_stream/stream_matcher_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.
 
 library scheduled_test.stream_matcher_test;
 
 import 'dart:async';
 
 import 'package:scheduled_test/scheduled_stream.dart';
 import 'package:scheduled_test/scheduled_test.dart';
@@ skipping 165 matching lines @@
   }, (errors) {
     expect(errors, hasLength(1));
     expect(errors.first.error.message, equals(
         "Expected: <100>\n"
         " Emitted: * 1"));
   });
 
   expectTestPasses("consumeThrough() consumes values through the given matcher",
       () {
     var stream = createStream();
-    stream.expect(consumeThrough(greaterThan(2)));
+    stream.expect(consumeThrough(inOrder([2, 3])));
     stream.expect(4);
   });
 
   expectTestPasses("consumeThrough() will stop if the first value matches", () {
     var stream = createStream();
-    stream.expect(consumeThrough(1));
-    stream.expect(2);
+    stream.expect(consumeThrough(inOrder([1, 2])));
+    stream.expect(3);
   });
 
   expectTestFails("consumeThrough() will fail if the stream ends before the "
       "value is reached", () {
-    createStream().expect(consumeThrough(100));
+    createStream().expect(consumeThrough(inOrder([5, 6])));
   }, (errors) {
     expect(errors, hasLength(1));
     expect(errors.first.error.message, equals(
-        "Expected: values followed by <100>\n"
+        "Expected: values followed by:\n"
+        "        |   * <5>\n"
+        "        |   * <6>\n"
         " Emitted: * 1\n"
         "          * 2\n"
         "          * 3\n"
         "          * 4\n"
         "          * 5\n"
         "   Which: unexpected end of stream"));
   });
 
   expectTestPasses("consumeWhile() consumes values while the given matcher "
       "matches", () {
     var stream = createStream();
     stream.expect(consumeWhile(lessThan(4)));
     stream.expect(4);
   });
 
+  expectTestPasses("consumeWhile() consumes values in chunks", () {
+    var stream = createStream();
+    stream.expect(consumeWhile(inOrder([anything, anything])));
+    stream.expect(5);
+  });
+
   expectTestPasses("consumeWhile() will stop if the first value doesn't match",
       () {
     var stream = createStream();
-    stream.expect(consumeWhile(2));
+    stream.expect(consumeWhile(inOrder([2, 3])));
     stream.expect(1);
   });
 
   expectTestPasses("either() will match if the first branch matches", () {
     createStream().expect(either(1, 100));
   });
 
   expectTestPasses("either() will match if the second branch matches", () {
     createStream().expect(either(100, 1));
   });
@@ skipping 84 matching lines @@
     expect(errors.first.error.message, equals(
         "Expected: is done\n"
         " Emitted: * 1\n"
         "          * 2\n"
         "          * 3\n"
         "          * 4\n"
         "          * 5\n"
         "   Which: stream wasn't finished"));
   });
 }