| 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.
 | 
| 
 |