| Index: pkg/dev_compiler/lib/js/es6/dart_sdk.js
|
| diff --git a/pkg/dev_compiler/lib/js/es6/dart_sdk.js b/pkg/dev_compiler/lib/js/es6/dart_sdk.js
|
| index 8e04bfc1d75c8383b38b0de694a111126c50aec1..7015400ee3a2afcf1c987ceba435c78011834ac4 100644
|
| --- a/pkg/dev_compiler/lib/js/es6/dart_sdk.js
|
| +++ b/pkg/dev_compiler/lib/js/es6/dart_sdk.js
|
| @@ -10437,7 +10437,7 @@ async.Stream$ = dart.generic(T => {
|
|
|
| if (async.Future.is(newValue)) {
|
| subscription.pause();
|
| - newValue.then(dart.void)(add, {onError: addError}).whenComplete(dart.bind(subscription, 'resume'));
|
| + newValue.then(dart.dynamic)(add, {onError: addError}).whenComplete(dart.bind(subscription, 'resume'));
|
| } else {
|
| controller.add(E.as(newValue));
|
| }
|
| @@ -18843,7 +18843,7 @@ async._DoneSubscription$ = dart.generic(T => {
|
| onDone(handleDone) {}
|
| pause(resumeSignal) {
|
| if (resumeSignal === void 0) resumeSignal = null;
|
| - if (resumeSignal != null) resumeSignal.then(dart.void)(dart.bind(this, _resume));
|
| + if (resumeSignal != null) resumeSignal.then(dart.dynamic)(dart.bind(this, _resume));
|
| this[_pauseCount] = dart.notNull(this[_pauseCount]) + 1;
|
| }
|
| resume() {
|
| @@ -39589,7 +39589,7 @@ io._FileStream = class _FileStream extends async.Stream$(core.List$(core.int)) {
|
| dart.fn(onReady, RandomAccessFileTovoid());
|
| const onOpenFile = (function(file) {
|
| if (dart.notNull(this[_position]) > 0) {
|
| - file.setPosition(this[_position]).then(dart.void)(onReady, {onError: dart.fn((e, s) => {
|
| + file.setPosition(this[_position]).then(dart.dynamic)(onReady, {onError: dart.fn((e, s) => {
|
| this[_controller].addError(e, core.StackTrace._check(s));
|
| this[_readInProgress] = false;
|
| this[_closeFile]();
|
| @@ -39606,7 +39606,7 @@ io._FileStream = class _FileStream extends async.Stream$(core.List$(core.int)) {
|
| }).bind(this);
|
| dart.fn(openFailed, dynamicAnddynamicTovoid());
|
| if (this[_path] != null) {
|
| - io.File.new(this[_path]).open({mode: io.FileMode.READ}).then(dart.void)(onOpenFile, {onError: openFailed});
|
| + io.File.new(this[_path]).open({mode: io.FileMode.READ}).then(dart.dynamic)(onOpenFile, {onError: openFailed});
|
| } else {
|
| try {
|
| onOpenFile(io._File._openStdioSync(0));
|
| @@ -43215,7 +43215,7 @@ io._StreamSinkImpl$ = dart.generic(T => {
|
| return this.done;
|
| }
|
| [_closeTarget]() {
|
| - this[_target].close().then(dart.void)(dart.bind(this, _completeDoneValue), {onError: dart.bind(this, _completeDoneError)});
|
| + this[_target].close().then(dart.dynamic)(dart.bind(this, _completeDoneValue), {onError: dart.bind(this, _completeDoneError)});
|
| }
|
| get done() {
|
| return this[_doneCompleter].future;
|
| @@ -43872,7 +43872,7 @@ io._HttpClientRequest = class _HttpClientRequest extends io._HttpOutboundMessage
|
| } else {
|
| future = FutureOfHttpClientResponse().value(response);
|
| }
|
| - future.then(dart.void)(dart.fn(v => this[_responseCompleter].complete(v), HttpClientResponseTovoid()), {onError: dart.bind(this[_responseCompleter], 'completeError')});
|
| + future.then(dart.dynamic)(dart.fn(v => this[_responseCompleter].complete(v), HttpClientResponseTovoid()), {onError: dart.bind(this[_responseCompleter], 'completeError')});
|
| }
|
| [_onError](error, stackTrace) {
|
| this[_responseCompleter].completeError(error, stackTrace);
|
| @@ -44517,7 +44517,7 @@ io._HttpClientConnection = class _HttpClientConnection extends core.Object {
|
| close() {
|
| this.closed = true;
|
| this[_httpClient][_connectionClosed](this);
|
| - this[_streamFuture].then(dart.void)(dart.fn(_ => this[_socket].destroy(), dynamicTovoid()));
|
| + this[_streamFuture].then(dart.dynamic)(dart.fn(_ => this[_socket].destroy(), dynamicTovoid()));
|
| }
|
| createProxyTunnel(host, port, proxy, callback) {
|
| let request = this.send(core.Uri.new({host: core.String._check(host), port: core.int._check(port)}), core.int._check(port), "CONNECT", io._Proxy._check(proxy));
|
| @@ -44676,7 +44676,7 @@ io._ConnectionTarget = class _ConnectionTarget extends core.Object {
|
| if (client.maxConnectionsPerHost != null && dart.notNull(this[_active].length) + dart.notNull(this[_connecting]) >= dart.notNull(client.maxConnectionsPerHost)) {
|
| let completer = async.Completer.new();
|
| this[_pending].add(dart.fn(() => {
|
| - this.connect(uriHost, uriPort, proxy, client).then(dart.void)(dart.bind(completer, 'complete'), {onError: dart.bind(completer, 'completeError')});
|
| + this.connect(uriHost, uriPort, proxy, client).then(dart.dynamic)(dart.bind(completer, 'complete'), {onError: dart.bind(completer, 'completeError')});
|
| }, VoidToNull()));
|
| return FutureOf_ConnectionInfo()._check(completer.future);
|
| }
|
| @@ -49218,7 +49218,7 @@ io._RawSecureSocket = class _RawSecureSocket extends async.Stream$(io.RawSocketE
|
| this[_closedWrite] = true;
|
| this[_closedRead] = true;
|
| if (this[_socket] != null) {
|
| - this[_socket].close().then(dart.void)(dart.bind(this, _completeCloseCompleter));
|
| + this[_socket].close().then(dart.dynamic)(dart.bind(this, _completeCloseCompleter));
|
| } else {
|
| this[_completeCloseCompleter]();
|
| }
|
| @@ -51579,7 +51579,7 @@ io._WebSocketTransformerImpl = class _WebSocketTransformerImpl extends core.Obje
|
| }
|
| bind(stream) {
|
| stream.listen(dart.fn(request => {
|
| - io._WebSocketTransformerImpl._upgrade(request, this[_protocolSelector], this[_compression]).then(dart.void)(dart.fn(webSocket => this[_controller].add(webSocket), WebSocketTovoid())).catchError(dart.bind(this[_controller], 'addError'));
|
| + io._WebSocketTransformerImpl._upgrade(request, this[_protocolSelector], this[_compression]).then(dart.dynamic)(dart.fn(webSocket => this[_controller].add(webSocket), WebSocketTovoid())).catchError(dart.bind(this[_controller], 'addError'));
|
| }, HttpRequestToNull()), {onDone: dart.fn(() => {
|
| this[_controller].close();
|
| }, VoidToNull())});
|
|
|