blob: 8110d3b975c0437ea32bcf43afa11e319e030d4b [file] [log] [blame]
// Copyright (c) 2017, 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 Future close()
/// NOTE: Writes to the [IOSink] may be buffered, and may not be flushed by a
/// call to close().
/// @description Checks that target consumer cannot be closed while stream is
/// being added to the consumer.
/// @author iarkh@unipro.ru
import "../../../Utils/expect.dart";
import "dart:async";
import "dart:io";
class MyStreamConsumer extends StreamConsumer<List<int>> {
Future addStream(Stream<List> stream) {
return new Future(() {});
}
Future close() {
return new Future(() {});
}
}
main() {
Stream<List<int>> stream = new Stream<List<int>>.fromIterable([
[1, 2],
[12],
[3, 22]
]);
StreamConsumer<List<int>> consumer = new MyStreamConsumer();
IOSink sink = new IOSink(consumer);
sink.addStream(stream).then((x) {
new Future.delayed(new Duration(seconds: 3)).then((_) {
sink.close();
});
});
Expect.throws(() {
sink.close();
}, (e) => e is StateError);
}