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 ac6d94922cb864995f27da4c7f83b2f040da4877..798e819660e3347a4a9171af6a374cb246936ceb 100644 |
--- a/tests/lib/async/stream_state_helper.dart |
+++ b/tests/lib/async/stream_state_helper.dart |
@@ -18,13 +18,17 @@ class StreamProtocolTest { |
StreamProtocolTest([bool broadcast = false]) { |
if (broadcast) { |
_controller = new StreamController.broadcast( |
- onPauseStateChange: _onPause, |
- onSubscriptionStateChange: _onSubcription); |
+ onListen: _onSubcription, |
+ onPause: _onPause, |
+ onResume: _onPause, |
+ onCancel: _onSubcription); |
// TODO(lrn): Make it work with multiple subscribers too. |
} else { |
_controller = new StreamController( |
- onPauseStateChange: _onPause, |
- onSubscriptionStateChange: _onSubcription); |
+ onListen: _onSubcription, |
+ onPause: _onPause, |
+ onResume: _onPause, |
+ onCancel: _onSubcription); |
} |
_onComplete = expectAsync0((){ |
_onComplete = null; // Being null marks the test to be complete. |