| Index: tests/lib_strong/async/stream_timeout_test.dart
|
| diff --git a/tests/lib_strong/async/stream_timeout_test.dart b/tests/lib_strong/async/stream_timeout_test.dart
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..e0854960d2564c22abed53dcaa8ae59878eb6dc8
|
| --- /dev/null
|
| +++ b/tests/lib_strong/async/stream_timeout_test.dart
|
| @@ -0,0 +1,182 @@
|
| +// 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.
|
| +
|
| +import "dart:async";
|
| +import "package:unittest/unittest.dart";
|
| +
|
| +main() {
|
| + const ms5 = const Duration(milliseconds: 5);
|
| + const twoSecs = const Duration(seconds: 2);
|
| +
|
| + test("stream timeout", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(ms5);
|
| + expect(tos.isBroadcast, false);
|
| + tos.handleError(expectAsync((e, s) {
|
| + expect(e, new isInstanceOf<TimeoutException>());
|
| + expect(s, null);
|
| + })).listen((v){ fail("Unexpected event"); });
|
| + });
|
| +
|
| + test("stream timeout add events", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(ms5, onTimeout: (sink) {
|
| + sink.add(42);
|
| + sink.addError("ERROR");
|
| + sink.close();
|
| + });
|
| + expect(tos.isBroadcast, false);
|
| + tos.listen(expectAsync((v) { expect(v, 42); }),
|
| + onError: expectAsync((e, s) { expect(e, "ERROR"); }),
|
| + onDone: expectAsync((){}));
|
| + });
|
| +
|
| + test("stream no timeout", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(twoSecs);
|
| + int ctr = 0;
|
| + tos.listen((v) {
|
| + expect(v, 42);
|
| + ctr++;
|
| + },
|
| + onError: (e, s) { fail("No error expected"); },
|
| + onDone: expectAsync(() {
|
| + expect(ctr, 2);
|
| + }));
|
| + expect(tos.isBroadcast, false);
|
| + c..add(42)..add(42)..close(); // Faster than a timeout!
|
| + });
|
| +
|
| + test("stream timeout after events", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(twoSecs);
|
| + expect(tos.isBroadcast, false);
|
| + int ctr = 0;
|
| + tos.listen((v) {
|
| + expect(v, 42);
|
| + ctr++;
|
| + },
|
| + onError: expectAsync((e, s) {
|
| + expect(ctr, 2);
|
| + expect(e, new isInstanceOf<TimeoutException>());
|
| + }));
|
| + c..add(42)..add(42); // No close, timeout after two events.
|
| + });
|
| +
|
| + test("broadcast stream timeout", () {
|
| + StreamController c = new StreamController.broadcast();
|
| + Stream tos = c.stream.timeout(ms5);
|
| + expect(tos.isBroadcast, true);
|
| + tos.handleError(expectAsync((e, s) {
|
| + expect(e, new isInstanceOf<TimeoutException>());
|
| + expect(s, null);
|
| + })).listen((v){ fail("Unexpected event"); });
|
| + });
|
| +
|
| + test("asBroadcast stream timeout", () {
|
| + StreamController c = new StreamController.broadcast();
|
| + Stream tos = c.stream.asBroadcastStream().timeout(ms5);
|
| + expect(tos.isBroadcast, true);
|
| + tos.handleError(expectAsync((e, s) {
|
| + expect(e, new isInstanceOf<TimeoutException>());
|
| + expect(s, null);
|
| + })).listen((v){ fail("Unexpected event"); });
|
| + });
|
| +
|
| + test("mapped stream timeout", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.map((x) => 2 * x).timeout(ms5);
|
| + expect(tos.isBroadcast, false);
|
| + tos.handleError(expectAsync((e, s) {
|
| + expect(e, new isInstanceOf<TimeoutException>());
|
| + expect(s, null);
|
| + })).listen((v){ fail("Unexpected event"); });
|
| + });
|
| +
|
| + test("events prevent timeout", () {
|
| + Stopwatch sw = new Stopwatch();
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(twoSecs, onTimeout: (_) {
|
| + int elapsed = sw.elapsedMilliseconds;
|
| + if (elapsed > 250) {
|
| + // This should not happen, but it does occasionally.
|
| + // Starving the periodic timer has made the test useless.
|
| + print("Periodic timer of 5 ms delayed $elapsed ms.");
|
| + return;
|
| + }
|
| + fail("Timeout not prevented by events");
|
| + throw "ERROR";
|
| + });
|
| + // Start the periodic timer before we start listening to the stream.
|
| + // This should reduce the flakiness of the test.
|
| + int ctr = 200; // send this many events at 5ms intervals. Then close.
|
| + new Timer.periodic(ms5, (timer) {
|
| + sw.reset();
|
| + c.add(42);
|
| + if (--ctr == 0) {
|
| + timer.cancel();
|
| + c.close();
|
| + }
|
| + });
|
| + sw.start();
|
| +
|
| + tos.listen((v) { expect(v, 42);}, onDone: expectAsync((){}));
|
| + });
|
| +
|
| + test("errors prevent timeout", () {
|
| + Stopwatch sw = new Stopwatch();
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(twoSecs, onTimeout: (_) {
|
| + int elapsed = sw.elapsedMilliseconds;
|
| + if (elapsed > 250) {
|
| + // This should not happen, but it does occasionally.
|
| + // Starving the periodic timer has made the test useless.
|
| + print("Periodic timer of 5 ms delayed $elapsed ms.");
|
| + return;
|
| + }
|
| + fail("Timeout not prevented by errors");
|
| + });
|
| +
|
| + // Start the periodic timer before we start listening to the stream.
|
| + // This should reduce the flakiness of the test.
|
| + int ctr = 200; // send this many error events at 5ms intervals. Then close.
|
| + new Timer.periodic(ms5, (timer) {
|
| + sw.reset();
|
| + c.addError("ERROR");
|
| + if (--ctr == 0) {
|
| + timer.cancel();
|
| + c.close();
|
| + }
|
| + });
|
| + sw.start();
|
| +
|
| + tos.listen((_) {},
|
| + onError: (e, s) {
|
| + expect(e, "ERROR");
|
| + },
|
| + onDone: expectAsync((){}));
|
| + });
|
| +
|
| + test("closing prevents timeout", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(twoSecs, onTimeout: (_) {
|
| + fail("Timeout not prevented by close");
|
| + });
|
| + tos.listen((_) {}, onDone: expectAsync((){}));
|
| + c.close();
|
| + });
|
| +
|
| + test("pausing prevents timeout", () {
|
| + StreamController c = new StreamController();
|
| + Stream tos = c.stream.timeout(ms5, onTimeout: (_) {
|
| + fail("Timeout not prevented by close");
|
| + });
|
| + var subscription = tos.listen((_) {}, onDone: expectAsync((){}));
|
| + subscription.pause();
|
| + new Timer(twoSecs, () {
|
| + c.close();
|
| + subscription.resume();
|
| + });
|
| + });
|
| +}
|
|
|