Index: tests/lib/async/stream_controller_async_test.dart |
diff --git a/tests/lib/async/stream_controller_async_test.dart b/tests/lib/async/stream_controller_async_test.dart |
index 36278bded8e7d7c2a871fe64e54e1ce286d5d4a3..91b4337b361de34f8ed700ca29b4c2cd75de9c19 100644 |
--- a/tests/lib/async/stream_controller_async_test.dart |
+++ b/tests/lib/async/stream_controller_async_test.dart |
@@ -86,7 +86,7 @@ testSingleController() { |
test("Single-subscription StreamController subscription changes", () { |
StreamController c = new StreamController(); |
- StreamSink sink = c.sink; |
+ EventSink sink = c.sink; |
Stream stream = c.stream; |
int counter = 0; |
var subscription; |
@@ -110,7 +110,7 @@ testSingleController() { |
" there is no subscriber", |
() { |
StreamController c = new StreamController(); |
- StreamSink sink = c.sink; |
+ EventSink sink = c.sink; |
Stream stream = c.stream; |
int counter = 0; |
sink.add(1); |
@@ -129,7 +129,7 @@ testSingleController() { |
test("Single-subscription StreamController subscription changes while firing", |
() { |
StreamController c = new StreamController(); |
- StreamSink sink = c.sink; |
+ EventSink sink = c.sink; |
Stream stream = c.stream; |
int counter = 0; |
var subscription = stream.listen(null); |
@@ -420,7 +420,7 @@ testRethrow() { |
Stream s = streamErrorTransform(c.stream, (e) { throw error; }); |
s.listen((_) { Expect.fail("unexpected value"); }, onError: expectAsync1( |
(AsyncError e) { Expect.identical(error, e); })); |
- c.signalError(null); |
+ c.addError(null); |
c.close(); |
}); |
} |