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