Index: sdk/lib/async/stream_impl.dart |
diff --git a/sdk/lib/async/stream_impl.dart b/sdk/lib/async/stream_impl.dart |
index 29cfbd1c3ce5cc1055f0f5240734352e7be9b7d3..c1cffd5b8c5800f2a18d4f5f2cc60676a3e014cf 100644 |
--- a/sdk/lib/async/stream_impl.dart |
+++ b/sdk/lib/async/stream_impl.dart |
@@ -144,9 +144,7 @@ class _BufferingStreamSubscription<T> implements StreamSubscription<T>, |
void onError(Function handleError) { |
if (handleError == null) handleError = _nullErrorHandler; |
- // We are not allowed to use 'void' as type argument for the generic type, |
- // so we use 'dynamic' instead. |
- _onError = _registerErrorHandler<dynamic>(handleError, _zone); |
+ _onError = _registerErrorHandler(handleError, _zone); |
} |
void onDone(void handleDone()) { |
@@ -1008,7 +1006,7 @@ class _StreamIterator<T> implements StreamIterator<T> { |
} |
Future cancel() { |
- StreamSubscription<T> subscription = _subscription; |
+ StreamSubscription subscription = _subscription; |
Object stateData = _stateData; |
_stateData = null; |
if (subscription != null) { |