| Index: pkg/barback/test/stream_replayer_test.dart
|
| diff --git a/pkg/barback/test/stream_replayer_test.dart b/pkg/barback/test/stream_replayer_test.dart
|
| index f341a2927fc2005d188b6b70cfd33580285852d9..9bc8224532b95f3bf1e4c722d5c0e1a037307020 100644
|
| --- a/pkg/barback/test/stream_replayer_test.dart
|
| +++ b/pkg/barback/test/stream_replayer_test.dart
|
| @@ -76,4 +76,26 @@ main() {
|
| expect(isClosed, isTrue);
|
| }), completes);
|
| });
|
| +
|
| + test("the wrapped stream isn't opened if there are no replays", () {
|
| + var isOpened = false;
|
| + var controller = new StreamController<int>(onListen: () {
|
| + isOpened = true;
|
| + });
|
| + var replayer = new StreamReplayer<int>(controller.stream);
|
| +
|
| + expect(pumpEventQueue().then((_) => isOpened), completion(isFalse));
|
| + });
|
| +
|
| + test("the wrapped stream isn't opened if no replays are opened", () {
|
| + var isOpened = false;
|
| + var controller = new StreamController<int>(onListen: () {
|
| + isOpened = true;
|
| + });
|
| + var replayer = new StreamReplayer<int>(controller.stream);
|
| + replayer.getReplay();
|
| + replayer.getReplay();
|
| +
|
| + expect(pumpEventQueue().then((_) => isOpened), completion(isFalse));
|
| + });
|
| }
|
|
|