blob: bec93fd3c6655deba4a2cc702f28be3e71746b97 [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 bool isClosed
/// Whether the stream is closed for adding more events.
/// If the controller is closed, the "done" event might not have been delivered
/// yet, but it has been scheduled, and it is too late to add more events.
///
/// @description Checks that the property returns correct value. Checks that an
/// error is thrown if events are added after the stream is closed. A broadcast
/// stream is checked.
/// @author kaigorodov
import "dart:async";
import "../../../Utils/expect.dart";
main() {
StreamController controller = new StreamController.broadcast();
Expect.isFalse(controller.isClosed);
List events1 = new List.empty(growable: true);
StreamSubscription ss = controller.stream.listen(
(event) {events1.add(event);});
Expect.isFalse(controller.isClosed);
controller.add(1);
Expect.isFalse(controller.isClosed);
controller.close();
Expect.isTrue(controller.isClosed);
Expect.throws(() => controller.add(0), null, "add() works after close()");
}