Index: lib/runtime/dart/async.js |
diff --git a/lib/runtime/dart/async.js b/lib/runtime/dart/async.js |
index d6ad2f5a9e3b07fd6fe301652048744d645f8880..1a903cf608c52099f578034ad25c200bb009cedd 100644 |
--- a/lib/runtime/dart/async.js |
+++ b/lib/runtime/dart/async.js |
@@ -920,7 +920,7 @@ var async; |
onData(handleData) { |
if (handleData == null) |
handleData = dart.as(_nullDataHandler, dart.functionType(dart.void, [T])); |
- this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _DataHandler); |
+ this[_onData] = dart.as(this[_zone].registerUnaryCallback(handleData), _DataHandler$(T)); |
} |
onError(handleError) { |
if (handleError == null) |
@@ -4303,7 +4303,7 @@ var async; |
if (handleDone == null) |
handleDone = _StreamHandlerTransformer[_defaultHandleDone]; |
return new (_HandlerEventSink$(S, T))(handleData, handleError, handleDone, outputSink); |
- }, _SinkMapper)); |
+ }, _SinkMapper$(S, T))); |
} |
bind(stream) { |
return super.bind(stream); |