blob: 8fb9a19cc7f213f2921c69d001086e86d36710f6 [file] [log] [blame]
// 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.
/// @assertion Stream<T> stream
/// The stream that this controller is controlling.
/// @description Checks Stream interface implementation
/// @author
import "dart:async";
import "../Stream/allTests_A03.lib.dart";
Stream<T> create<T>(Iterable<T> data, {bool isError(T element)?}) {
StreamController<T> sc = new StreamController<T>();
for (T e in data) {
if (isError != null && isError(e)) {
sc.addError(e as Object);
} else {
new Future(() => sc.close()); // close stream controller later
main() {