Chromium Code Reviews| 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..4be57a4f13333feb3efd462a99286a75b1d075f3 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: [Subscribed:${_controller.hasListener}, " |
|
Anders Johnsen
2013/04/11 18:10:13
Ditto.
floitsch
2013/04/12 09:29:22
Done.
|
| "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() => "[Subscribers:$hasListener, Paused:$isPaused]"; |
|
Anders Johnsen
2013/04/11 18:10:13
Subscribers -> Listener
floitsch
2013/04/12 09:29:22
Done.
|
| } |
| @@ -283,7 +283,7 @@ class LogAnyEvent extends Event { |
| return true; |
| } |
| bool _testSubcribe(StreamController c) { |
| - _actual = "*[Subscribers:${c.hasSubscribers}, Paused:${c.isPaused}]"; |
| + _actual = "*[Subscribers:${c.hasListener}, Paused:${c.isPaused}]"; |
|
Anders Johnsen
2013/04/11 18:10:13
Ditto.
floitsch
2013/04/12 09:29:22
Done.
|
| return true; |
| } |