Change ScheduledProcess's output streams over to be ScheduledStreams.

pkg/scheduled_test/lib/src/stream_matcher.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;
 
 import 'dart:async';
 import 'dart:collection';
 
 import '../scheduled_stream.dart';
@@ skipping 64 matching lines @@
   new _EitherMatcher(streamMatcher1, streamMatcher2);
 
 /// A matcher that consumes [streamMatcher] if it matches, or nothing otherwise.
 ///
 /// This matcher will always match a stream. It exists to consume values that
 /// may or may not be emitted by a stream.
 ///
 /// [streamMatcher] can be a [StreamMatcher], a [Matcher], or an [Object].
 StreamMatcher allow(streamMatcher) => new _AllowMatcher(streamMatcher);
 
+/// A matcher that asserts that a stream never emits values matching
+/// [streamMatcher].
+///
+/// This will consume the remainder of a stream.
+///
+/// [streamMatcher] can be a [StreamMatcher], a [Matcher], or an [Object].
+StreamMatcher never(streamMatcher) => new _NeverMatcher(streamMatcher);
+
 /// A matcher that matches a stream that emits no more values.
 StreamMatcher get isDone => new _IsDoneMatcher();
 
 /// See [nextValue].
 class _NextValueMatcher implements StreamMatcher {
   final Matcher _matcher;
 
   _NextValueMatcher(matcher)
       : _matcher = wrapMatcher(matcher);
 
@@ skipping 177 matching lines @@
     });
   }
 
   String toString() {
     return new StringDescription('allow\n')
         .add(prefixLines(_matcher.toString()))
         .toString();
   }
 }
 
+/// See [never].
+class _NeverMatcher implements StreamMatcher {
+  final StreamMatcher _matcher;
+
+  _NeverMatcher(streamMatcher)
+      : _matcher = new StreamMatcher.wrap(streamMatcher);
+
+  Future<Description> tryMatch(ScheduledStream stream) {
+    consumeNext() {
+      return stream.hasNext.then((hasNext) {
+        if (!hasNext) return new Future.value();
+
+        var fork = stream.fork();
+        return _matcher.tryMatch(fork).whenComplete(fork.close)
+            .then((description) {
+          if (description != null) {
+            return stream.next().then((_) => consumeNext());
+          }
+
+          return new StringDescription("matched\n")
+              .add(prefixLines(_matcher.toString(), prefix: '  '));
+        });
+      });
+    }
+
+    return consumeNext();
+  }
+
+  String toString() =>
+    'never\n${prefixLines(_matcher.toString(), prefix: '  ')}';
+}
+
 /// See [isDone].
 class _IsDoneMatcher implements StreamMatcher {
   _IsDoneMatcher();
 
   Future<Description> tryMatch(ScheduledStream stream) {
     return stream.hasNext.then((hasNext) {
       if (!hasNext) return null;
       return new StringDescription("stream wasn't finished");
     });
   }
 
   String toString() => 'is done';
 }