| Index: tests/lib/async/stream_state_helper.dart
|
| diff --git a/tests/lib/async/stream_state_helper.dart b/tests/lib/async/stream_state_helper.dart
|
| index 8f9b33fe389e617f17f215402fcf1dceeee7b365..b982d9d23be4e82fd13fec277e913907f31fbeac 100644
|
| --- a/tests/lib/async/stream_state_helper.dart
|
| +++ b/tests/lib/async/stream_state_helper.dart
|
| @@ -105,7 +105,7 @@ class StreamProtocolTest {
|
| _withNextExpectation((Event expect) {
|
| if (!expect.matchSubscriptionChange(_controller)) {
|
| _fail("Expected: $expect\n"
|
| - "Found: [Subscribed:${_controller.hasSubscribers}, "
|
| + "Found: [Has listener:${_controller.hasListener}, "
|
| "Paused:${_controller.isPaused}]");
|
| }
|
| });
|
| @@ -159,12 +159,12 @@ class StreamProtocolTest {
|
| }
|
| _expectations.add(new PauseCallbackEvent(isPaused, action));
|
| }
|
| - void expectSubscription(bool hasSubscribers, bool isPaused, [void action()]) {
|
| + void expectSubscription(bool hasListener, bool isPaused, [void action()]) {
|
| if (_onComplete == null) {
|
| _fail("Adding expectation after completing");
|
| }
|
| _expectations.add(
|
| - new SubscriptionCallbackEvent(hasSubscribers, isPaused, action));
|
| + new SubscriptionCallbackEvent(hasListener, isPaused, action));
|
| }
|
|
|
| void _fail(String message) {
|
| @@ -252,14 +252,14 @@ class PauseCallbackEvent extends Event {
|
| }
|
|
|
| class SubscriptionCallbackEvent extends Event {
|
| - final bool hasSubscribers;
|
| + final bool hasListener;
|
| final bool isPaused;
|
| - SubscriptionCallbackEvent(this.hasSubscribers, this.isPaused, void action())
|
| + SubscriptionCallbackEvent(this.hasListener, this.isPaused, void action())
|
| : super(action);
|
| bool _testSubscribe(StreamController c) {
|
| - return hasSubscribers == c.hasSubscribers && isPaused == c.isPaused;
|
| + return hasListener == c.hasListener && isPaused == c.isPaused;
|
| }
|
| - String toString() => "[Subscribers:$hasSubscribers, Paused:$isPaused]";
|
| + String toString() => "[Has listener:$hasListener, Paused:$isPaused]";
|
| }
|
|
|
|
|
| @@ -283,7 +283,7 @@ class LogAnyEvent extends Event {
|
| return true;
|
| }
|
| bool _testSubcribe(StreamController c) {
|
| - _actual = "*[Subscribers:${c.hasSubscribers}, Paused:${c.isPaused}]";
|
| + _actual = "*[Has listener:${c.hasListener}, Paused:${c.isPaused}]";
|
| return true;
|
| }
|
|
|
|
|