| OLD | NEW |
| 1 dart_library.library('dart/html', null, /* Imports */[ | 1 dart_library.library('dart/html', null, /* Imports */[ |
| 2 'dart/_runtime', | 2 'dart/_runtime', |
| 3 'dart/math', | 3 'dart/math', |
| 4 'dart/core', | 4 'dart/core', |
| 5 'dart/_js_helper', | 5 'dart/_js_helper', |
| 6 'dart/collection', | 6 'dart/collection', |
| 7 'dart/async', | 7 'dart/async', |
| 8 'dart/_foreign_helper', | 8 'dart/_foreign_helper', |
| 9 'dart/isolate' | 9 'dart/isolate' |
| 10 ], /* Lazy imports */[ | 10 ], /* Lazy imports */[ |
| 11 'dart/_metadata', | 11 'dart/_metadata', |
| 12 'dart/html_common' | 12 'dart/html_common' |
| 13 ], function(exports, dart, math, core, _js_helper, collection, async, _foreign_h
elper, isolate, _metadata, html_common) { | 13 ], function(exports, dart, math, core, _js_helper, collection, $async, _foreign_
helper, isolate, _metadata, html_common) { |
| 14 'use strict'; | 14 'use strict'; |
| 15 let dartx = dart.dartx; | 15 let dartx = dart.dartx; |
| 16 dart.export(exports, math, ['Rectangle', 'Point'], []); | 16 dart.export(exports, math, ['Rectangle', 'Point'], []); |
| 17 class DartHtmlDomObject extends core.Object { | 17 class DartHtmlDomObject extends core.Object { |
| 18 DartHtmlDomObject() { | 18 DartHtmlDomObject() { |
| 19 this.raw = null; | 19 this.raw = null; |
| 20 } | 20 } |
| 21 internal_() { | 21 internal_() { |
| 22 this.raw = null; | 22 this.raw = null; |
| 23 } | 23 } |
| (...skipping 5488 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5512 class Events extends core.Object { | 5512 class Events extends core.Object { |
| 5513 Events(ptr) { | 5513 Events(ptr) { |
| 5514 this[_ptr] = ptr; | 5514 this[_ptr] = ptr; |
| 5515 } | 5515 } |
| 5516 get(type) { | 5516 get(type) { |
| 5517 return new _EventStream(this[_ptr], type, false); | 5517 return new _EventStream(this[_ptr], type, false); |
| 5518 } | 5518 } |
| 5519 } | 5519 } |
| 5520 dart.setSignature(Events, { | 5520 dart.setSignature(Events, { |
| 5521 constructors: () => ({Events: [Events, [EventTarget]]}), | 5521 constructors: () => ({Events: [Events, [EventTarget]]}), |
| 5522 methods: () => ({get: [async.Stream, [core.String]]}) | 5522 methods: () => ({get: [$async.Stream, [core.String]]}) |
| 5523 }); | 5523 }); |
| 5524 class ElementEvents extends Events { | 5524 class ElementEvents extends Events { |
| 5525 ElementEvents(ptr) { | 5525 ElementEvents(ptr) { |
| 5526 super.Events(ptr); | 5526 super.Events(ptr); |
| 5527 } | 5527 } |
| 5528 get(type) { | 5528 get(type) { |
| 5529 if (dart.notNull(ElementEvents.webkitEvents.keys[dartx.contains](type[dart
x.toLowerCase]()))) { | 5529 if (dart.notNull(ElementEvents.webkitEvents.keys[dartx.contains](type[dart
x.toLowerCase]()))) { |
| 5530 if (dart.notNull(html_common.Device.isWebKit)) { | 5530 if (dart.notNull(html_common.Device.isWebKit)) { |
| 5531 return new _ElementEventStreamImpl(this[_ptr], ElementEvents.webkitEve
nts.get(type[dartx.toLowerCase]()), false); | 5531 return new _ElementEventStreamImpl(this[_ptr], ElementEvents.webkitEve
nts.get(type[dartx.toLowerCase]()), false); |
| 5532 } | 5532 } |
| (...skipping 594 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 6127 return HttpRequest.request(url, {method: 'POST', withCredentials: withCred
entials, responseType: responseType, requestHeaders: requestHeaders, sendData: f
ormData, onProgress: onProgress}); | 6127 return HttpRequest.request(url, {method: 'POST', withCredentials: withCred
entials, responseType: responseType, requestHeaders: requestHeaders, sendData: f
ormData, onProgress: onProgress}); |
| 6128 } | 6128 } |
| 6129 static request(url, opts) { | 6129 static request(url, opts) { |
| 6130 let method = opts && 'method' in opts ? opts.method : null; | 6130 let method = opts && 'method' in opts ? opts.method : null; |
| 6131 let withCredentials = opts && 'withCredentials' in opts ? opts.withCredent
ials : null; | 6131 let withCredentials = opts && 'withCredentials' in opts ? opts.withCredent
ials : null; |
| 6132 let responseType = opts && 'responseType' in opts ? opts.responseType : nu
ll; | 6132 let responseType = opts && 'responseType' in opts ? opts.responseType : nu
ll; |
| 6133 let mimeType = opts && 'mimeType' in opts ? opts.mimeType : null; | 6133 let mimeType = opts && 'mimeType' in opts ? opts.mimeType : null; |
| 6134 let requestHeaders = opts && 'requestHeaders' in opts ? opts.requestHeader
s : null; | 6134 let requestHeaders = opts && 'requestHeaders' in opts ? opts.requestHeader
s : null; |
| 6135 let sendData = opts && 'sendData' in opts ? opts.sendData : null; | 6135 let sendData = opts && 'sendData' in opts ? opts.sendData : null; |
| 6136 let onProgress = opts && 'onProgress' in opts ? opts.onProgress : null; | 6136 let onProgress = opts && 'onProgress' in opts ? opts.onProgress : null; |
| 6137 let completer = async.Completer$(HttpRequest).new(); | 6137 let completer = $async.Completer$(HttpRequest).new(); |
| 6138 let xhr = HttpRequest.new(); | 6138 let xhr = HttpRequest.new(); |
| 6139 if (method == null) { | 6139 if (method == null) { |
| 6140 method = 'GET'; | 6140 method = 'GET'; |
| 6141 } | 6141 } |
| 6142 xhr.open(method, url, {async: true}); | 6142 xhr.open(method, url, {async: true}); |
| 6143 if (withCredentials != null) { | 6143 if (withCredentials != null) { |
| 6144 xhr.withCredentials = withCredentials; | 6144 xhr.withCredentials = withCredentials; |
| 6145 } | 6145 } |
| 6146 if (responseType != null) { | 6146 if (responseType != null) { |
| 6147 xhr.responseType = responseType; | 6147 xhr.responseType = responseType; |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 6187 } | 6187 } |
| 6188 static get supportsOverrideMimeType() { | 6188 static get supportsOverrideMimeType() { |
| 6189 return true; | 6189 return true; |
| 6190 } | 6190 } |
| 6191 static requestCrossOrigin(url, opts) { | 6191 static requestCrossOrigin(url, opts) { |
| 6192 let method = opts && 'method' in opts ? opts.method : null; | 6192 let method = opts && 'method' in opts ? opts.method : null; |
| 6193 let sendData = opts && 'sendData' in opts ? opts.sendData : null; | 6193 let sendData = opts && 'sendData' in opts ? opts.sendData : null; |
| 6194 if (dart.notNull(HttpRequest.supportsCrossOrigin)) { | 6194 if (dart.notNull(HttpRequest.supportsCrossOrigin)) { |
| 6195 return dart.as(HttpRequest.request(url, {method: method, sendData: sendD
ata}).then(dart.fn(xhr => { | 6195 return dart.as(HttpRequest.request(url, {method: method, sendData: sendD
ata}).then(dart.fn(xhr => { |
| 6196 return xhr.responseText; | 6196 return xhr.responseText; |
| 6197 }, dart.dynamic, [HttpRequest])), async.Future$(core.String)); | 6197 }, dart.dynamic, [HttpRequest])), $async.Future$(core.String)); |
| 6198 } | 6198 } |
| 6199 } | 6199 } |
| 6200 get responseHeaders() { | 6200 get responseHeaders() { |
| 6201 let headers = dart.map(); | 6201 let headers = dart.map(); |
| 6202 let headersString = this.getAllResponseHeaders(); | 6202 let headersString = this.getAllResponseHeaders(); |
| 6203 if (headersString == null) { | 6203 if (headersString == null) { |
| 6204 return headers; | 6204 return headers; |
| 6205 } | 6205 } |
| 6206 let headersList = headersString[dartx.split]('\r\n'); | 6206 let headersList = headersString[dartx.split]('\r\n'); |
| 6207 for (let header of headersList) { | 6207 for (let header of headersList) { |
| 6208 if (dart.notNull(header[dartx.isEmpty])) { | 6208 if (dart.notNull(header[dartx.isEmpty])) { |
| 6209 continue; | 6209 continue; |
| 6210 } | 6210 } |
| 6211 let splitIdx = header[dartx.indexOf](': '); | 6211 let splitIdx = header[dartx.indexOf](': '); |
| 6212 if (splitIdx == -1) { | 6212 if (splitIdx == -1) { |
| 6213 continue; | 6213 continue; |
| 6214 } | 6214 } |
| 6215 let key = header[dartx.substring](0, splitIdx)[dartx.toLowerCase](); | 6215 let key = header[dartx.substring](0, splitIdx)[dartx.toLowerCase](); |
| 6216 let value = header[dartx.substring](dart.notNull(splitIdx) + 2); | 6216 let value = header[dartx.substring](dart.notNull(splitIdx) + 2); |
| 6217 if (dart.notNull(headers.containsKey(key))) { | 6217 if (dart.notNull(headers.containsKey(key))) { |
| 6218 headers.set(key, `${headers.get(key)}, ${value}`); | 6218 headers.set(key, `${headers.get(key)}, ${value}`); |
| 6219 } else { | 6219 } else { |
| 6220 headers.set(key, value); | 6220 headers.set(key, value); |
| 6221 } | 6221 } |
| 6222 } | 6222 } |
| 6223 return headers; | 6223 return headers; |
| 6224 } | 6224 } |
| 6225 open(method, url, opts) { | 6225 open(method, url, opts) { |
| 6226 let async = opts && 'async' in opts ? opts.async : null; | 6226 let async$ = opts && 'async' in opts ? opts.async : null; |
| 6227 let user = opts && 'user' in opts ? opts.user : null; | 6227 let user = opts && 'user' in opts ? opts.user : null; |
| 6228 let password = opts && 'password' in opts ? opts.password : null; | 6228 let password = opts && 'password' in opts ? opts.password : null; |
| 6229 if (async == null && user == null && password == null) { | 6229 if (async$ == null && user == null && password == null) { |
| 6230 this.raw.open(method, url); | 6230 this.raw.open(method, url); |
| 6231 } else { | 6231 } else { |
| 6232 this.raw.open(method, url, async, user, password); | 6232 this.raw.open(method, url, async$, user, password); |
| 6233 } | 6233 } |
| 6234 } | 6234 } |
| 6235 get responseType() { | 6235 get responseType() { |
| 6236 return this.raw.responseType; | 6236 return this.raw.responseType; |
| 6237 } | 6237 } |
| 6238 set responseType(value) { | 6238 set responseType(value) { |
| 6239 this.raw.responseType = value; | 6239 this.raw.responseType = value; |
| 6240 } | 6240 } |
| 6241 static _() { | 6241 static _() { |
| 6242 dart.throw(new core.UnsupportedError("Not supported")); | 6242 dart.throw(new core.UnsupportedError("Not supported")); |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 6372 overrideMimeType: [dart.void, [core.String]], | 6372 overrideMimeType: [dart.void, [core.String]], |
| 6373 [_overrideMimeType_1]: [dart.void, [dart.dynamic]], | 6373 [_overrideMimeType_1]: [dart.void, [dart.dynamic]], |
| 6374 send: [dart.void, [], [dart.dynamic]], | 6374 send: [dart.void, [], [dart.dynamic]], |
| 6375 [_send_1]: [dart.void, []], | 6375 [_send_1]: [dart.void, []], |
| 6376 [_send_2]: [dart.void, [Document]], | 6376 [_send_2]: [dart.void, [Document]], |
| 6377 [_send_3]: [dart.void, [core.String]], | 6377 [_send_3]: [dart.void, [core.String]], |
| 6378 setRequestHeader: [dart.void, [core.String, core.String]], | 6378 setRequestHeader: [dart.void, [core.String, core.String]], |
| 6379 [_setRequestHeader_1]: [dart.void, [dart.dynamic, dart.dynamic]] | 6379 [_setRequestHeader_1]: [dart.void, [dart.dynamic, dart.dynamic]] |
| 6380 }), | 6380 }), |
| 6381 statics: () => ({ | 6381 statics: () => ({ |
| 6382 getString: [async.Future$(core.String), [core.String], {withCredentials: c
ore.bool, onProgress: dart.functionType(dart.void, [ProgressEvent])}], | 6382 getString: [$async.Future$(core.String), [core.String], {withCredentials:
core.bool, onProgress: dart.functionType(dart.void, [ProgressEvent])}], |
| 6383 postFormData: [async.Future$(HttpRequest), [core.String, core.Map$(core.St
ring, core.String)], {withCredentials: core.bool, responseType: core.String, req
uestHeaders: core.Map$(core.String, core.String), onProgress: dart.functionType(
dart.void, [ProgressEvent])}], | 6383 postFormData: [$async.Future$(HttpRequest), [core.String, core.Map$(core.S
tring, core.String)], {withCredentials: core.bool, responseType: core.String, re
questHeaders: core.Map$(core.String, core.String), onProgress: dart.functionType
(dart.void, [ProgressEvent])}], |
| 6384 request: [async.Future$(HttpRequest), [core.String], {method: core.String,
withCredentials: core.bool, responseType: core.String, mimeType: core.String, r
equestHeaders: core.Map$(core.String, core.String), sendData: dart.dynamic, onPr
ogress: dart.functionType(dart.void, [ProgressEvent])}], | 6384 request: [$async.Future$(HttpRequest), [core.String], {method: core.String
, withCredentials: core.bool, responseType: core.String, mimeType: core.String,
requestHeaders: core.Map$(core.String, core.String), sendData: dart.dynamic, onP
rogress: dart.functionType(dart.void, [ProgressEvent])}], |
| 6385 requestCrossOrigin: [async.Future$(core.String), [core.String], {method: c
ore.String, sendData: core.String}], | 6385 requestCrossOrigin: [$async.Future$(core.String), [core.String], {method:
core.String, sendData: core.String}], |
| 6386 _create_1: [HttpRequest, []], | 6386 _create_1: [HttpRequest, []], |
| 6387 internalCreateHttpRequest: [HttpRequest, []] | 6387 internalCreateHttpRequest: [HttpRequest, []] |
| 6388 }), | 6388 }), |
| 6389 names: ['getString', 'postFormData', 'request', 'requestCrossOrigin', '_crea
te_1', 'internalCreateHttpRequest'] | 6389 names: ['getString', 'postFormData', 'request', 'requestCrossOrigin', '_crea
te_1', 'internalCreateHttpRequest'] |
| 6390 }); | 6390 }); |
| 6391 HttpRequest[dart.metadata] = () => [dart.const(new _metadata.DomName('XMLHttpR
equest')), dart.const(new _js_helper.Native("XMLHttpRequest"))]; | 6391 HttpRequest[dart.metadata] = () => [dart.const(new _metadata.DomName('XMLHttpR
equest')), dart.const(new _js_helper.Native("XMLHttpRequest"))]; |
| 6392 HttpRequest.DONE = 4; | 6392 HttpRequest.DONE = 4; |
| 6393 HttpRequest.HEADERS_RECEIVED = 2; | 6393 HttpRequest.HEADERS_RECEIVED = 2; |
| 6394 HttpRequest.LOADING = 3; | 6394 HttpRequest.LOADING = 3; |
| 6395 HttpRequest.OPENED = 1; | 6395 HttpRequest.OPENED = 1; |
| (...skipping 1131 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 7527 get vendor() { | 7527 get vendor() { |
| 7528 return dart.as(wrap_jso(this.raw.vendor), core.String); | 7528 return dart.as(wrap_jso(this.raw.vendor), core.String); |
| 7529 } | 7529 } |
| 7530 get vendorSub() { | 7530 get vendorSub() { |
| 7531 return dart.as(wrap_jso(this.raw.vendorSub), core.String); | 7531 return dart.as(wrap_jso(this.raw.vendorSub), core.String); |
| 7532 } | 7532 } |
| 7533 getBattery() { | 7533 getBattery() { |
| 7534 return this[_getBattery_1](); | 7534 return this[_getBattery_1](); |
| 7535 } | 7535 } |
| 7536 [_getBattery_1]() { | 7536 [_getBattery_1]() { |
| 7537 return dart.as(wrap_jso(this.raw.getBattery()), async.Future); | 7537 return dart.as(wrap_jso(this.raw.getBattery()), $async.Future); |
| 7538 } | 7538 } |
| 7539 getStorageUpdates() { | 7539 getStorageUpdates() { |
| 7540 this[_getStorageUpdates_1](); | 7540 this[_getStorageUpdates_1](); |
| 7541 return; | 7541 return; |
| 7542 } | 7542 } |
| 7543 [_getStorageUpdates_1]() { | 7543 [_getStorageUpdates_1]() { |
| 7544 return wrap_jso(this.raw.getStorageUpdates()); | 7544 return wrap_jso(this.raw.getStorageUpdates()); |
| 7545 } | 7545 } |
| 7546 registerProtocolHandler(scheme, url, title) { | 7546 registerProtocolHandler(scheme, url, title) { |
| 7547 this[_registerProtocolHandler_1](scheme, url, title); | 7547 this[_registerProtocolHandler_1](scheme, url, title); |
| (...skipping 13 matching lines...) Expand all Loading... |
| 7561 } | 7561 } |
| 7562 } | 7562 } |
| 7563 Navigator[dart.implements] = () => [NavigatorCpu]; | 7563 Navigator[dart.implements] = () => [NavigatorCpu]; |
| 7564 dart.defineNamedConstructor(Navigator, 'internal_'); | 7564 dart.defineNamedConstructor(Navigator, 'internal_'); |
| 7565 dart.setSignature(Navigator, { | 7565 dart.setSignature(Navigator, { |
| 7566 constructors: () => ({ | 7566 constructors: () => ({ |
| 7567 _: [Navigator, []], | 7567 _: [Navigator, []], |
| 7568 internal_: [Navigator, []] | 7568 internal_: [Navigator, []] |
| 7569 }), | 7569 }), |
| 7570 methods: () => ({ | 7570 methods: () => ({ |
| 7571 getBattery: [async.Future, []], | 7571 getBattery: [$async.Future, []], |
| 7572 [_getBattery_1]: [async.Future, []], | 7572 [_getBattery_1]: [$async.Future, []], |
| 7573 getStorageUpdates: [dart.void, []], | 7573 getStorageUpdates: [dart.void, []], |
| 7574 [_getStorageUpdates_1]: [dart.void, []], | 7574 [_getStorageUpdates_1]: [dart.void, []], |
| 7575 registerProtocolHandler: [dart.void, [core.String, core.String, core.Strin
g]], | 7575 registerProtocolHandler: [dart.void, [core.String, core.String, core.Strin
g]], |
| 7576 [_registerProtocolHandler_1]: [dart.void, [dart.dynamic, dart.dynamic, dar
t.dynamic]], | 7576 [_registerProtocolHandler_1]: [dart.void, [dart.dynamic, dart.dynamic, dar
t.dynamic]], |
| 7577 sendBeacon: [core.bool, [core.String, core.String]], | 7577 sendBeacon: [core.bool, [core.String, core.String]], |
| 7578 [_sendBeacon_1]: [core.bool, [dart.dynamic, dart.dynamic]] | 7578 [_sendBeacon_1]: [core.bool, [dart.dynamic, dart.dynamic]] |
| 7579 }), | 7579 }), |
| 7580 statics: () => ({internalCreateNavigator: [Navigator, []]}), | 7580 statics: () => ({internalCreateNavigator: [Navigator, []]}), |
| 7581 names: ['internalCreateNavigator'] | 7581 names: ['internalCreateNavigator'] |
| 7582 }); | 7582 }); |
| (...skipping 1020 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 8603 const _scrollTo_1 = Symbol('_scrollTo_1'); | 8603 const _scrollTo_1 = Symbol('_scrollTo_1'); |
| 8604 const _scrollTo_2 = Symbol('_scrollTo_2'); | 8604 const _scrollTo_2 = Symbol('_scrollTo_2'); |
| 8605 const _scrollTo_3 = Symbol('_scrollTo_3'); | 8605 const _scrollTo_3 = Symbol('_scrollTo_3'); |
| 8606 const _scrollTo_4 = Symbol('_scrollTo_4'); | 8606 const _scrollTo_4 = Symbol('_scrollTo_4'); |
| 8607 const _showModalDialog_1 = Symbol('_showModalDialog_1'); | 8607 const _showModalDialog_1 = Symbol('_showModalDialog_1'); |
| 8608 const _showModalDialog_2 = Symbol('_showModalDialog_2'); | 8608 const _showModalDialog_2 = Symbol('_showModalDialog_2'); |
| 8609 const _showModalDialog_3 = Symbol('_showModalDialog_3'); | 8609 const _showModalDialog_3 = Symbol('_showModalDialog_3'); |
| 8610 const _stop_1 = Symbol('_stop_1'); | 8610 const _stop_1 = Symbol('_stop_1'); |
| 8611 class Window extends EventTarget { | 8611 class Window extends EventTarget { |
| 8612 get animationFrame() { | 8612 get animationFrame() { |
| 8613 let completer = async.Completer$(core.num).sync(); | 8613 let completer = $async.Completer$(core.num).sync(); |
| 8614 this.requestAnimationFrame(dart.fn(time => { | 8614 this.requestAnimationFrame(dart.fn(time => { |
| 8615 completer.complete(time); | 8615 completer.complete(time); |
| 8616 }, dart.void, [core.num])); | 8616 }, dart.void, [core.num])); |
| 8617 return completer.future; | 8617 return completer.future; |
| 8618 } | 8618 } |
| 8619 get document() { | 8619 get document() { |
| 8620 return dart.as(wrap_jso(this.raw.document), Document); | 8620 return dart.as(wrap_jso(this.raw.document), Document); |
| 8621 } | 8621 } |
| 8622 [_open2](url, name) { | 8622 [_open2](url, name) { |
| 8623 return dart.as(wrap_jso(this.raw.open(url, name)), WindowBase); | 8623 return dart.as(wrap_jso(this.raw.open(url, name)), WindowBase); |
| (...skipping 1597 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 10221 let useCapture = opts && 'useCapture' in opts ? opts.useCapture : false; | 10221 let useCapture = opts && 'useCapture' in opts ? opts.useCapture : false; |
| 10222 return new (_ElementListEventStreamImpl$(T))(dart.as(e, core.Iterable$(E
lement)), this[_eventType], useCapture); | 10222 return new (_ElementListEventStreamImpl$(T))(dart.as(e, core.Iterable$(E
lement)), this[_eventType], useCapture); |
| 10223 } | 10223 } |
| 10224 getEventType(target) { | 10224 getEventType(target) { |
| 10225 return this[_eventType]; | 10225 return this[_eventType]; |
| 10226 } | 10226 } |
| 10227 } | 10227 } |
| 10228 dart.setSignature(EventStreamProvider, { | 10228 dart.setSignature(EventStreamProvider, { |
| 10229 constructors: () => ({EventStreamProvider: [EventStreamProvider$(T), [core
.String]]}), | 10229 constructors: () => ({EventStreamProvider: [EventStreamProvider$(T), [core
.String]]}), |
| 10230 methods: () => ({ | 10230 methods: () => ({ |
| 10231 forTarget: [async.Stream$(T), [EventTarget], {useCapture: core.bool}], | 10231 forTarget: [$async.Stream$(T), [EventTarget], {useCapture: core.bool}], |
| 10232 forElement: [ElementStream$(T), [Element], {useCapture: core.bool}], | 10232 forElement: [ElementStream$(T), [Element], {useCapture: core.bool}], |
| 10233 [_forElementList]: [ElementStream$(T), [ElementList], {useCapture: core.
bool}], | 10233 [_forElementList]: [ElementStream$(T), [ElementList], {useCapture: core.
bool}], |
| 10234 getEventType: [core.String, [EventTarget]] | 10234 getEventType: [core.String, [EventTarget]] |
| 10235 }) | 10235 }) |
| 10236 }); | 10236 }); |
| 10237 return EventStreamProvider; | 10237 return EventStreamProvider; |
| 10238 }); | 10238 }); |
| 10239 let EventStreamProvider = EventStreamProvider$(); | 10239 let EventStreamProvider = EventStreamProvider$(); |
| 10240 const ElementStream$ = dart.generic(function(T) { | 10240 const ElementStream$ = dart.generic(function(T) { |
| 10241 class ElementStream extends core.Object {} | 10241 class ElementStream extends core.Object {} |
| 10242 ElementStream[dart.implements] = () => [async.Stream$(T)]; | 10242 ElementStream[dart.implements] = () => [$async.Stream$(T)]; |
| 10243 return ElementStream; | 10243 return ElementStream; |
| 10244 }); | 10244 }); |
| 10245 let ElementStream = ElementStream$(); | 10245 let ElementStream = ElementStream$(); |
| 10246 const _target = Symbol('_target'); | 10246 const _target = Symbol('_target'); |
| 10247 const _useCapture = Symbol('_useCapture'); | 10247 const _useCapture = Symbol('_useCapture'); |
| 10248 const _EventStream$ = dart.generic(function(T) { | 10248 const _EventStream$ = dart.generic(function(T) { |
| 10249 class _EventStream extends async.Stream$(T) { | 10249 class _EventStream extends $async.Stream$(T) { |
| 10250 _EventStream(target, eventType, useCapture) { | 10250 _EventStream(target, eventType, useCapture) { |
| 10251 this[_target] = target; | 10251 this[_target] = target; |
| 10252 this[_eventType] = eventType; | 10252 this[_eventType] = eventType; |
| 10253 this[_useCapture] = useCapture; | 10253 this[_useCapture] = useCapture; |
| 10254 super.Stream(); | 10254 super.Stream(); |
| 10255 } | 10255 } |
| 10256 asBroadcastStream(opts) { | 10256 asBroadcastStream(opts) { |
| 10257 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 10257 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 10258 dart.as(onListen, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10258 dart.as(onListen, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10259 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 10259 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 10260 dart.as(onCancel, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10260 dart.as(onCancel, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10261 return this; | 10261 return this; |
| 10262 } | 10262 } |
| 10263 get isBroadcast() { | 10263 get isBroadcast() { |
| 10264 return true; | 10264 return true; |
| 10265 } | 10265 } |
| 10266 listen(onData, opts) { | 10266 listen(onData, opts) { |
| 10267 dart.as(onData, dart.functionType(dart.void, [T])); | 10267 dart.as(onData, dart.functionType(dart.void, [T])); |
| 10268 let onError = opts && 'onError' in opts ? opts.onError : null; | 10268 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 10269 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 10269 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
| 10270 dart.as(onDone, dart.functionType(dart.void, [])); | 10270 dart.as(onDone, dart.functionType(dart.void, [])); |
| 10271 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 10271 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 10272 return new (_EventStreamSubscription$(T))(this[_target], this[_eventType
], onData, this[_useCapture]); | 10272 return new (_EventStreamSubscription$(T))(this[_target], this[_eventType
], onData, this[_useCapture]); |
| 10273 } | 10273 } |
| 10274 } | 10274 } |
| 10275 dart.setSignature(_EventStream, { | 10275 dart.setSignature(_EventStream, { |
| 10276 constructors: () => ({_EventStream: [_EventStream$(T), [EventTarget, core.
String, core.bool]]}), | 10276 constructors: () => ({_EventStream: [_EventStream$(T), [EventTarget, core.
String, core.bool]]}), |
| 10277 methods: () => ({ | 10277 methods: () => ({ |
| 10278 asBroadcastStream: [async.Stream$(T), [], {onListen: dart.functionType(d
art.void, [async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.void
, [async.StreamSubscription$(T)])}], | 10278 asBroadcastStream: [$async.Stream$(T), [], {onListen: dart.functionType(
dart.void, [$async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.vo
id, [$async.StreamSubscription$(T)])}], |
| 10279 listen: [async.StreamSubscription$(T), [dart.functionType(dart.void, [T]
)], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnE
rror: core.bool}] | 10279 listen: [$async.StreamSubscription$(T), [dart.functionType(dart.void, [T
])], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOn
Error: core.bool}] |
| 10280 }) | 10280 }) |
| 10281 }); | 10281 }); |
| 10282 return _EventStream; | 10282 return _EventStream; |
| 10283 }); | 10283 }); |
| 10284 let _EventStream = _EventStream$(); | 10284 let _EventStream = _EventStream$(); |
| 10285 const _ElementEventStreamImpl$ = dart.generic(function(T) { | 10285 const _ElementEventStreamImpl$ = dart.generic(function(T) { |
| 10286 class _ElementEventStreamImpl extends _EventStream$(T) { | 10286 class _ElementEventStreamImpl extends _EventStream$(T) { |
| 10287 _ElementEventStreamImpl(target, eventType, useCapture) { | 10287 _ElementEventStreamImpl(target, eventType, useCapture) { |
| 10288 super._EventStream(dart.as(target, EventTarget), dart.as(eventType, core
.String), dart.as(useCapture, core.bool)); | 10288 super._EventStream(dart.as(target, EventTarget), dart.as(eventType, core
.String), dart.as(useCapture, core.bool)); |
| 10289 } | 10289 } |
| 10290 matches(selector) { | 10290 matches(selector) { |
| 10291 return dart.as(this.where(dart.fn(event => dart.as(dart.dcall(event.targ
et.matchesWithAncestors, selector), core.bool), core.bool, [T])).map(dart.fn(e =
> { | 10291 return dart.as(this.where(dart.fn(event => dart.as(dart.dcall(event.targ
et.matchesWithAncestors, selector), core.bool), core.bool, [T])).map(dart.fn(e =
> { |
| 10292 dart.as(e, T); | 10292 dart.as(e, T); |
| 10293 e[_selector] = selector; | 10293 e[_selector] = selector; |
| 10294 return e; | 10294 return e; |
| 10295 }, dart.dynamic, [T])), async.Stream$(T)); | 10295 }, dart.dynamic, [T])), $async.Stream$(T)); |
| 10296 } | 10296 } |
| 10297 capture(onData) { | 10297 capture(onData) { |
| 10298 dart.as(onData, dart.functionType(dart.void, [T])); | 10298 dart.as(onData, dart.functionType(dart.void, [T])); |
| 10299 return new (_EventStreamSubscription$(T))(this[_target], this[_eventType
], onData, true); | 10299 return new (_EventStreamSubscription$(T))(this[_target], this[_eventType
], onData, true); |
| 10300 } | 10300 } |
| 10301 } | 10301 } |
| 10302 _ElementEventStreamImpl[dart.implements] = () => [ElementStream$(T)]; | 10302 _ElementEventStreamImpl[dart.implements] = () => [ElementStream$(T)]; |
| 10303 dart.setSignature(_ElementEventStreamImpl, { | 10303 dart.setSignature(_ElementEventStreamImpl, { |
| 10304 constructors: () => ({_ElementEventStreamImpl: [_ElementEventStreamImpl$(T
), [dart.dynamic, dart.dynamic, dart.dynamic]]}), | 10304 constructors: () => ({_ElementEventStreamImpl: [_ElementEventStreamImpl$(T
), [dart.dynamic, dart.dynamic, dart.dynamic]]}), |
| 10305 methods: () => ({ | 10305 methods: () => ({ |
| 10306 matches: [async.Stream$(T), [core.String]], | 10306 matches: [$async.Stream$(T), [core.String]], |
| 10307 capture: [async.StreamSubscription$(T), [dart.functionType(dart.void, [T
])]] | 10307 capture: [$async.StreamSubscription$(T), [dart.functionType(dart.void, [
T])]] |
| 10308 }) | 10308 }) |
| 10309 }); | 10309 }); |
| 10310 return _ElementEventStreamImpl; | 10310 return _ElementEventStreamImpl; |
| 10311 }); | 10311 }); |
| 10312 let _ElementEventStreamImpl = _ElementEventStreamImpl$(); | 10312 let _ElementEventStreamImpl = _ElementEventStreamImpl$(); |
| 10313 const _targetList = Symbol('_targetList'); | 10313 const _targetList = Symbol('_targetList'); |
| 10314 const _ElementListEventStreamImpl$ = dart.generic(function(T) { | 10314 const _ElementListEventStreamImpl$ = dart.generic(function(T) { |
| 10315 class _ElementListEventStreamImpl extends async.Stream$(T) { | 10315 class _ElementListEventStreamImpl extends $async.Stream$(T) { |
| 10316 _ElementListEventStreamImpl(targetList, eventType, useCapture) { | 10316 _ElementListEventStreamImpl(targetList, eventType, useCapture) { |
| 10317 this[_targetList] = targetList; | 10317 this[_targetList] = targetList; |
| 10318 this[_eventType] = eventType; | 10318 this[_eventType] = eventType; |
| 10319 this[_useCapture] = useCapture; | 10319 this[_useCapture] = useCapture; |
| 10320 super.Stream(); | 10320 super.Stream(); |
| 10321 } | 10321 } |
| 10322 matches(selector) { | 10322 matches(selector) { |
| 10323 return dart.as(this.where(dart.fn(event => dart.as(dart.dcall(event.targ
et.matchesWithAncestors, selector), core.bool), core.bool, [T])).map(dart.fn(e =
> { | 10323 return dart.as(this.where(dart.fn(event => dart.as(dart.dcall(event.targ
et.matchesWithAncestors, selector), core.bool), core.bool, [T])).map(dart.fn(e =
> { |
| 10324 dart.as(e, T); | 10324 dart.as(e, T); |
| 10325 e[_selector] = selector; | 10325 e[_selector] = selector; |
| 10326 return e; | 10326 return e; |
| 10327 }, dart.dynamic, [T])), async.Stream$(T)); | 10327 }, dart.dynamic, [T])), $async.Stream$(T)); |
| 10328 } | 10328 } |
| 10329 listen(onData, opts) { | 10329 listen(onData, opts) { |
| 10330 dart.as(onData, dart.functionType(dart.void, [T])); | 10330 dart.as(onData, dart.functionType(dart.void, [T])); |
| 10331 let onError = opts && 'onError' in opts ? opts.onError : null; | 10331 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 10332 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 10332 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
| 10333 dart.as(onDone, dart.functionType(dart.void, [])); | 10333 dart.as(onDone, dart.functionType(dart.void, [])); |
| 10334 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 10334 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 10335 let pool = new _StreamPool.broadcast(); | 10335 let pool = new _StreamPool.broadcast(); |
| 10336 for (let target of this[_targetList]) { | 10336 for (let target of this[_targetList]) { |
| 10337 pool.add(new _EventStream(target, this[_eventType], this[_useCapture])
); | 10337 pool.add(new _EventStream(target, this[_eventType], this[_useCapture])
); |
| 10338 } | 10338 } |
| 10339 return dart.as(pool.stream.listen(onData, {onError: onError, onDone: onD
one, cancelOnError: cancelOnError}), async.StreamSubscription$(T)); | 10339 return dart.as(pool.stream.listen(onData, {onError: onError, onDone: onD
one, cancelOnError: cancelOnError}), $async.StreamSubscription$(T)); |
| 10340 } | 10340 } |
| 10341 capture(onData) { | 10341 capture(onData) { |
| 10342 dart.as(onData, dart.functionType(dart.void, [T])); | 10342 dart.as(onData, dart.functionType(dart.void, [T])); |
| 10343 let pool = new _StreamPool.broadcast(); | 10343 let pool = new _StreamPool.broadcast(); |
| 10344 for (let target of this[_targetList]) { | 10344 for (let target of this[_targetList]) { |
| 10345 pool.add(new _EventStream(target, this[_eventType], true)); | 10345 pool.add(new _EventStream(target, this[_eventType], true)); |
| 10346 } | 10346 } |
| 10347 return dart.as(pool.stream.listen(onData), async.StreamSubscription$(T))
; | 10347 return dart.as(pool.stream.listen(onData), $async.StreamSubscription$(T)
); |
| 10348 } | 10348 } |
| 10349 asBroadcastStream(opts) { | 10349 asBroadcastStream(opts) { |
| 10350 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 10350 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 10351 dart.as(onListen, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10351 dart.as(onListen, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10352 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 10352 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 10353 dart.as(onCancel, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10353 dart.as(onCancel, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10354 return this; | 10354 return this; |
| 10355 } | 10355 } |
| 10356 get isBroadcast() { | 10356 get isBroadcast() { |
| 10357 return true; | 10357 return true; |
| 10358 } | 10358 } |
| 10359 } | 10359 } |
| 10360 _ElementListEventStreamImpl[dart.implements] = () => [ElementStream$(T)]; | 10360 _ElementListEventStreamImpl[dart.implements] = () => [ElementStream$(T)]; |
| 10361 dart.setSignature(_ElementListEventStreamImpl, { | 10361 dart.setSignature(_ElementListEventStreamImpl, { |
| 10362 constructors: () => ({_ElementListEventStreamImpl: [_ElementListEventStrea
mImpl$(T), [core.Iterable$(Element), core.String, core.bool]]}), | 10362 constructors: () => ({_ElementListEventStreamImpl: [_ElementListEventStrea
mImpl$(T), [core.Iterable$(Element), core.String, core.bool]]}), |
| 10363 methods: () => ({ | 10363 methods: () => ({ |
| 10364 matches: [async.Stream$(T), [core.String]], | 10364 matches: [$async.Stream$(T), [core.String]], |
| 10365 listen: [async.StreamSubscription$(T), [dart.functionType(dart.void, [T]
)], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnE
rror: core.bool}], | 10365 listen: [$async.StreamSubscription$(T), [dart.functionType(dart.void, [T
])], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOn
Error: core.bool}], |
| 10366 capture: [async.StreamSubscription$(T), [dart.functionType(dart.void, [T
])]], | 10366 capture: [$async.StreamSubscription$(T), [dart.functionType(dart.void, [
T])]], |
| 10367 asBroadcastStream: [async.Stream$(T), [], {onListen: dart.functionType(d
art.void, [async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.void
, [async.StreamSubscription$(T)])}] | 10367 asBroadcastStream: [$async.Stream$(T), [], {onListen: dart.functionType(
dart.void, [$async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.vo
id, [$async.StreamSubscription$(T)])}] |
| 10368 }) | 10368 }) |
| 10369 }); | 10369 }); |
| 10370 return _ElementListEventStreamImpl; | 10370 return _ElementListEventStreamImpl; |
| 10371 }); | 10371 }); |
| 10372 let _ElementListEventStreamImpl = _ElementListEventStreamImpl$(); | 10372 let _ElementListEventStreamImpl = _ElementListEventStreamImpl$(); |
| 10373 const _onData = Symbol('_onData'); | 10373 const _onData = Symbol('_onData'); |
| 10374 const _pauseCount = Symbol('_pauseCount'); | 10374 const _pauseCount = Symbol('_pauseCount'); |
| 10375 const _tryResume = Symbol('_tryResume'); | 10375 const _tryResume = Symbol('_tryResume'); |
| 10376 const _canceled = Symbol('_canceled'); | 10376 const _canceled = Symbol('_canceled'); |
| 10377 const _unlisten = Symbol('_unlisten'); | 10377 const _unlisten = Symbol('_unlisten'); |
| 10378 const _EventStreamSubscription$ = dart.generic(function(T) { | 10378 const _EventStreamSubscription$ = dart.generic(function(T) { |
| 10379 class _EventStreamSubscription extends async.StreamSubscription$(T) { | 10379 class _EventStreamSubscription extends $async.StreamSubscription$(T) { |
| 10380 _EventStreamSubscription(target, eventType, onData, useCapture) { | 10380 _EventStreamSubscription(target, eventType, onData, useCapture) { |
| 10381 this[_target] = target; | 10381 this[_target] = target; |
| 10382 this[_eventType] = eventType; | 10382 this[_eventType] = eventType; |
| 10383 this[_useCapture] = useCapture; | 10383 this[_useCapture] = useCapture; |
| 10384 this[_onData] = _wrapZone(dart.as(onData, __CastType2)); | 10384 this[_onData] = _wrapZone(dart.as(onData, __CastType2)); |
| 10385 this[_pauseCount] = 0; | 10385 this[_pauseCount] = 0; |
| 10386 this[_tryResume](); | 10386 this[_tryResume](); |
| 10387 } | 10387 } |
| 10388 cancel() { | 10388 cancel() { |
| 10389 if (dart.notNull(this[_canceled])) return null; | 10389 if (dart.notNull(this[_canceled])) return null; |
| (...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 10430 this[_target].addEventListener(this[_eventType], dart.as(this[_onData]
, EventListener), this[_useCapture]); | 10430 this[_target].addEventListener(this[_eventType], dart.as(this[_onData]
, EventListener), this[_useCapture]); |
| 10431 } | 10431 } |
| 10432 } | 10432 } |
| 10433 [_unlisten]() { | 10433 [_unlisten]() { |
| 10434 if (this[_onData] != null) { | 10434 if (this[_onData] != null) { |
| 10435 this[_target].removeEventListener(this[_eventType], dart.as(this[_onDa
ta], EventListener), this[_useCapture]); | 10435 this[_target].removeEventListener(this[_eventType], dart.as(this[_onDa
ta], EventListener), this[_useCapture]); |
| 10436 } | 10436 } |
| 10437 } | 10437 } |
| 10438 asFuture(futureValue) { | 10438 asFuture(futureValue) { |
| 10439 if (futureValue === void 0) futureValue = null; | 10439 if (futureValue === void 0) futureValue = null; |
| 10440 let completer = async.Completer.new(); | 10440 let completer = $async.Completer.new(); |
| 10441 return completer.future; | 10441 return completer.future; |
| 10442 } | 10442 } |
| 10443 } | 10443 } |
| 10444 dart.setSignature(_EventStreamSubscription, { | 10444 dart.setSignature(_EventStreamSubscription, { |
| 10445 constructors: () => ({_EventStreamSubscription: [_EventStreamSubscription$
(T), [EventTarget, core.String, dart.dynamic, core.bool]]}), | 10445 constructors: () => ({_EventStreamSubscription: [_EventStreamSubscription$
(T), [EventTarget, core.String, dart.dynamic, core.bool]]}), |
| 10446 methods: () => ({ | 10446 methods: () => ({ |
| 10447 cancel: [async.Future, []], | 10447 cancel: [$async.Future, []], |
| 10448 onData: [dart.void, [dart.functionType(dart.void, [T])]], | 10448 onData: [dart.void, [dart.functionType(dart.void, [T])]], |
| 10449 onError: [dart.void, [core.Function]], | 10449 onError: [dart.void, [core.Function]], |
| 10450 onDone: [dart.void, [dart.functionType(dart.void, [])]], | 10450 onDone: [dart.void, [dart.functionType(dart.void, [])]], |
| 10451 pause: [dart.void, [], [async.Future]], | 10451 pause: [dart.void, [], [$async.Future]], |
| 10452 resume: [dart.void, []], | 10452 resume: [dart.void, []], |
| 10453 [_tryResume]: [dart.void, []], | 10453 [_tryResume]: [dart.void, []], |
| 10454 [_unlisten]: [dart.void, []], | 10454 [_unlisten]: [dart.void, []], |
| 10455 asFuture: [async.Future, [], [dart.dynamic]] | 10455 asFuture: [$async.Future, [], [dart.dynamic]] |
| 10456 }) | 10456 }) |
| 10457 }); | 10457 }); |
| 10458 return _EventStreamSubscription; | 10458 return _EventStreamSubscription; |
| 10459 }); | 10459 }); |
| 10460 let _EventStreamSubscription = _EventStreamSubscription$(); | 10460 let _EventStreamSubscription = _EventStreamSubscription$(); |
| 10461 const CustomStream$ = dart.generic(function(T) { | 10461 const CustomStream$ = dart.generic(function(T) { |
| 10462 class CustomStream extends core.Object {} | 10462 class CustomStream extends core.Object {} |
| 10463 CustomStream[dart.implements] = () => [async.Stream$(T)]; | 10463 CustomStream[dart.implements] = () => [$async.Stream$(T)]; |
| 10464 return CustomStream; | 10464 return CustomStream; |
| 10465 }); | 10465 }); |
| 10466 let CustomStream = CustomStream$(); | 10466 let CustomStream = CustomStream$(); |
| 10467 const _streamController = Symbol('_streamController'); | 10467 const _streamController = Symbol('_streamController'); |
| 10468 const _type = Symbol('_type'); | 10468 const _type = Symbol('_type'); |
| 10469 const _CustomEventStreamImpl$ = dart.generic(function(T) { | 10469 const _CustomEventStreamImpl$ = dart.generic(function(T) { |
| 10470 class _CustomEventStreamImpl extends async.Stream$(T) { | 10470 class _CustomEventStreamImpl extends $async.Stream$(T) { |
| 10471 _CustomEventStreamImpl(type) { | 10471 _CustomEventStreamImpl(type) { |
| 10472 this[_streamController] = null; | 10472 this[_streamController] = null; |
| 10473 this[_type] = null; | 10473 this[_type] = null; |
| 10474 super.Stream(); | 10474 super.Stream(); |
| 10475 this[_type] = type; | 10475 this[_type] = type; |
| 10476 this[_streamController] = async.StreamController$(T).broadcast({sync: tr
ue}); | 10476 this[_streamController] = $async.StreamController$(T).broadcast({sync: t
rue}); |
| 10477 } | 10477 } |
| 10478 listen(onData, opts) { | 10478 listen(onData, opts) { |
| 10479 dart.as(onData, dart.functionType(dart.void, [T])); | 10479 dart.as(onData, dart.functionType(dart.void, [T])); |
| 10480 let onError = opts && 'onError' in opts ? opts.onError : null; | 10480 let onError = opts && 'onError' in opts ? opts.onError : null; |
| 10481 let onDone = opts && 'onDone' in opts ? opts.onDone : null; | 10481 let onDone = opts && 'onDone' in opts ? opts.onDone : null; |
| 10482 dart.as(onDone, dart.functionType(dart.void, [])); | 10482 dart.as(onDone, dart.functionType(dart.void, [])); |
| 10483 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; | 10483 let cancelOnError = opts && 'cancelOnError' in opts ? opts.cancelOnError
: null; |
| 10484 return this[_streamController].stream.listen(onData, {onError: onError,
onDone: onDone, cancelOnError: cancelOnError}); | 10484 return this[_streamController].stream.listen(onData, {onError: onError,
onDone: onDone, cancelOnError: cancelOnError}); |
| 10485 } | 10485 } |
| 10486 asBroadcastStream(opts) { | 10486 asBroadcastStream(opts) { |
| 10487 let onListen = opts && 'onListen' in opts ? opts.onListen : null; | 10487 let onListen = opts && 'onListen' in opts ? opts.onListen : null; |
| 10488 dart.as(onListen, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10488 dart.as(onListen, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10489 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; | 10489 let onCancel = opts && 'onCancel' in opts ? opts.onCancel : null; |
| 10490 dart.as(onCancel, dart.functionType(dart.void, [async.StreamSubscription
$(T)])); | 10490 dart.as(onCancel, dart.functionType(dart.void, [$async.StreamSubscriptio
n$(T)])); |
| 10491 return this[_streamController].stream; | 10491 return this[_streamController].stream; |
| 10492 } | 10492 } |
| 10493 get isBroadcast() { | 10493 get isBroadcast() { |
| 10494 return true; | 10494 return true; |
| 10495 } | 10495 } |
| 10496 add(event) { | 10496 add(event) { |
| 10497 dart.as(event, T); | 10497 dart.as(event, T); |
| 10498 if (event.type == this[_type]) this[_streamController].add(event); | 10498 if (event.type == this[_type]) this[_streamController].add(event); |
| 10499 } | 10499 } |
| 10500 } | 10500 } |
| 10501 _CustomEventStreamImpl[dart.implements] = () => [CustomStream$(T)]; | 10501 _CustomEventStreamImpl[dart.implements] = () => [CustomStream$(T)]; |
| 10502 dart.setSignature(_CustomEventStreamImpl, { | 10502 dart.setSignature(_CustomEventStreamImpl, { |
| 10503 constructors: () => ({_CustomEventStreamImpl: [_CustomEventStreamImpl$(T),
[core.String]]}), | 10503 constructors: () => ({_CustomEventStreamImpl: [_CustomEventStreamImpl$(T),
[core.String]]}), |
| 10504 methods: () => ({ | 10504 methods: () => ({ |
| 10505 listen: [async.StreamSubscription$(T), [dart.functionType(dart.void, [T]
)], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOnE
rror: core.bool}], | 10505 listen: [$async.StreamSubscription$(T), [dart.functionType(dart.void, [T
])], {onError: core.Function, onDone: dart.functionType(dart.void, []), cancelOn
Error: core.bool}], |
| 10506 asBroadcastStream: [async.Stream$(T), [], {onListen: dart.functionType(d
art.void, [async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.void
, [async.StreamSubscription$(T)])}], | 10506 asBroadcastStream: [$async.Stream$(T), [], {onListen: dart.functionType(
dart.void, [$async.StreamSubscription$(T)]), onCancel: dart.functionType(dart.vo
id, [$async.StreamSubscription$(T)])}], |
| 10507 add: [dart.void, [T]] | 10507 add: [dart.void, [T]] |
| 10508 }) | 10508 }) |
| 10509 }); | 10509 }); |
| 10510 return _CustomEventStreamImpl; | 10510 return _CustomEventStreamImpl; |
| 10511 }); | 10511 }); |
| 10512 let _CustomEventStreamImpl = _CustomEventStreamImpl$(); | 10512 let _CustomEventStreamImpl = _CustomEventStreamImpl$(); |
| 10513 class _WrappedEvent extends core.Object { | 10513 class _WrappedEvent extends core.Object { |
| 10514 _WrappedEvent(wrapped) { | 10514 _WrappedEvent(wrapped) { |
| 10515 this.wrapped = wrapped; | 10515 this.wrapped = wrapped; |
| 10516 this[_selector] = null; | 10516 this[_selector] = null; |
| (...skipping 311 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 10828 _CustomKeyEventStreamImpl[dart.implements] = () => [CustomStream$(KeyEvent)]; | 10828 _CustomKeyEventStreamImpl[dart.implements] = () => [CustomStream$(KeyEvent)]; |
| 10829 dart.setSignature(_CustomKeyEventStreamImpl, { | 10829 dart.setSignature(_CustomKeyEventStreamImpl, { |
| 10830 constructors: () => ({_CustomKeyEventStreamImpl: [_CustomKeyEventStreamImpl,
[core.String]]}), | 10830 constructors: () => ({_CustomKeyEventStreamImpl: [_CustomKeyEventStreamImpl,
[core.String]]}), |
| 10831 methods: () => ({add: [dart.void, [KeyEvent]]}) | 10831 methods: () => ({add: [dart.void, [KeyEvent]]}) |
| 10832 }); | 10832 }); |
| 10833 const _subscriptions = Symbol('_subscriptions'); | 10833 const _subscriptions = Symbol('_subscriptions'); |
| 10834 const _controller = Symbol('_controller'); | 10834 const _controller = Symbol('_controller'); |
| 10835 const _StreamPool$ = dart.generic(function(T) { | 10835 const _StreamPool$ = dart.generic(function(T) { |
| 10836 class _StreamPool extends core.Object { | 10836 class _StreamPool extends core.Object { |
| 10837 broadcast() { | 10837 broadcast() { |
| 10838 this[_subscriptions] = core.Map$(async.Stream$(T), async.StreamSubscript
ion$(T)).new(); | 10838 this[_subscriptions] = core.Map$($async.Stream$(T), $async.StreamSubscri
ption$(T)).new(); |
| 10839 this[_controller] = null; | 10839 this[_controller] = null; |
| 10840 this[_controller] = async.StreamController$(T).broadcast({sync: true, on
Cancel: dart.bind(this, 'close')}); | 10840 this[_controller] = $async.StreamController$(T).broadcast({sync: true, o
nCancel: dart.bind(this, 'close')}); |
| 10841 } | 10841 } |
| 10842 get stream() { | 10842 get stream() { |
| 10843 return this[_controller].stream; | 10843 return this[_controller].stream; |
| 10844 } | 10844 } |
| 10845 add(stream) { | 10845 add(stream) { |
| 10846 dart.as(stream, async.Stream$(T)); | 10846 dart.as(stream, $async.Stream$(T)); |
| 10847 if (dart.notNull(this[_subscriptions].containsKey(stream))) return; | 10847 if (dart.notNull(this[_subscriptions].containsKey(stream))) return; |
| 10848 this[_subscriptions].set(stream, stream.listen(dart.bind(this[_controlle
r], 'add'), {onError: dart.bind(this[_controller], 'addError'), onDone: dart.fn(
(() => this.remove(stream)).bind(this), dart.void, [])})); | 10848 this[_subscriptions].set(stream, stream.listen(dart.bind(this[_controlle
r], 'add'), {onError: dart.bind(this[_controller], 'addError'), onDone: dart.fn(
(() => this.remove(stream)).bind(this), dart.void, [])})); |
| 10849 } | 10849 } |
| 10850 remove(stream) { | 10850 remove(stream) { |
| 10851 dart.as(stream, async.Stream$(T)); | 10851 dart.as(stream, $async.Stream$(T)); |
| 10852 let subscription = this[_subscriptions].remove(stream); | 10852 let subscription = this[_subscriptions].remove(stream); |
| 10853 if (subscription != null) subscription.cancel(); | 10853 if (subscription != null) subscription.cancel(); |
| 10854 } | 10854 } |
| 10855 close() { | 10855 close() { |
| 10856 for (let subscription of this[_subscriptions].values) { | 10856 for (let subscription of this[_subscriptions].values) { |
| 10857 subscription.cancel(); | 10857 subscription.cancel(); |
| 10858 } | 10858 } |
| 10859 this[_subscriptions].clear(); | 10859 this[_subscriptions].clear(); |
| 10860 this[_controller].close(); | 10860 this[_controller].close(); |
| 10861 } | 10861 } |
| 10862 } | 10862 } |
| 10863 dart.defineNamedConstructor(_StreamPool, 'broadcast'); | 10863 dart.defineNamedConstructor(_StreamPool, 'broadcast'); |
| 10864 dart.setSignature(_StreamPool, { | 10864 dart.setSignature(_StreamPool, { |
| 10865 constructors: () => ({broadcast: [_StreamPool$(T), []]}), | 10865 constructors: () => ({broadcast: [_StreamPool$(T), []]}), |
| 10866 methods: () => ({ | 10866 methods: () => ({ |
| 10867 add: [dart.void, [async.Stream$(T)]], | 10867 add: [dart.void, [$async.Stream$(T)]], |
| 10868 remove: [dart.void, [async.Stream$(T)]], | 10868 remove: [dart.void, [$async.Stream$(T)]], |
| 10869 close: [dart.void, []] | 10869 close: [dart.void, []] |
| 10870 }) | 10870 }) |
| 10871 }); | 10871 }); |
| 10872 return _StreamPool; | 10872 return _StreamPool; |
| 10873 }); | 10873 }); |
| 10874 let _StreamPool = _StreamPool$(); | 10874 let _StreamPool = _StreamPool$(); |
| 10875 const _eventTypeGetter = Symbol('_eventTypeGetter'); | 10875 const _eventTypeGetter = Symbol('_eventTypeGetter'); |
| 10876 const _CustomEventStreamProvider$ = dart.generic(function(T) { | 10876 const _CustomEventStreamProvider$ = dart.generic(function(T) { |
| 10877 class _CustomEventStreamProvider extends core.Object { | 10877 class _CustomEventStreamProvider extends core.Object { |
| 10878 _CustomEventStreamProvider(eventTypeGetter) { | 10878 _CustomEventStreamProvider(eventTypeGetter) { |
| (...skipping 15 matching lines...) Expand all Loading... |
| 10894 return dart.as(dart.dcall(this[_eventTypeGetter], target), core.String); | 10894 return dart.as(dart.dcall(this[_eventTypeGetter], target), core.String); |
| 10895 } | 10895 } |
| 10896 get [_eventType]() { | 10896 get [_eventType]() { |
| 10897 return dart.throw(new core.UnsupportedError('Access type through getEven
tType method.')); | 10897 return dart.throw(new core.UnsupportedError('Access type through getEven
tType method.')); |
| 10898 } | 10898 } |
| 10899 } | 10899 } |
| 10900 _CustomEventStreamProvider[dart.implements] = () => [EventStreamProvider$(T)
]; | 10900 _CustomEventStreamProvider[dart.implements] = () => [EventStreamProvider$(T)
]; |
| 10901 dart.setSignature(_CustomEventStreamProvider, { | 10901 dart.setSignature(_CustomEventStreamProvider, { |
| 10902 constructors: () => ({_CustomEventStreamProvider: [_CustomEventStreamProvi
der$(T), [dart.dynamic]]}), | 10902 constructors: () => ({_CustomEventStreamProvider: [_CustomEventStreamProvi
der$(T), [dart.dynamic]]}), |
| 10903 methods: () => ({ | 10903 methods: () => ({ |
| 10904 forTarget: [async.Stream$(T), [EventTarget], {useCapture: core.bool}], | 10904 forTarget: [$async.Stream$(T), [EventTarget], {useCapture: core.bool}], |
| 10905 forElement: [ElementStream$(T), [Element], {useCapture: core.bool}], | 10905 forElement: [ElementStream$(T), [Element], {useCapture: core.bool}], |
| 10906 [_forElementList]: [ElementStream$(T), [ElementList], {useCapture: core.
bool}], | 10906 [_forElementList]: [ElementStream$(T), [ElementList], {useCapture: core.
bool}], |
| 10907 getEventType: [core.String, [EventTarget]] | 10907 getEventType: [core.String, [EventTarget]] |
| 10908 }) | 10908 }) |
| 10909 }); | 10909 }); |
| 10910 return _CustomEventStreamProvider; | 10910 return _CustomEventStreamProvider; |
| 10911 }); | 10911 }); |
| 10912 let _CustomEventStreamProvider = _CustomEventStreamProvider$(); | 10912 let _CustomEventStreamProvider = _CustomEventStreamProvider$(); |
| 10913 class _Html5NodeValidator extends core.Object { | 10913 class _Html5NodeValidator extends core.Object { |
| 10914 _Html5NodeValidator(opts) { | 10914 _Html5NodeValidator(opts) { |
| (...skipping 1436 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12351 forward: [dart.void, []], | 12351 forward: [dart.void, []], |
| 12352 go: [dart.void, [core.int]] | 12352 go: [dart.void, [core.int]] |
| 12353 }), | 12353 }), |
| 12354 statics: () => ({_createSafe: [HistoryBase, [dart.dynamic]]}), | 12354 statics: () => ({_createSafe: [HistoryBase, [dart.dynamic]]}), |
| 12355 names: ['_createSafe'] | 12355 names: ['_createSafe'] |
| 12356 }); | 12356 }); |
| 12357 class Platform extends core.Object {} | 12357 class Platform extends core.Object {} |
| 12358 Platform.supportsSimd = false; | 12358 Platform.supportsSimd = false; |
| 12359 dart.defineLazyProperties(Platform, { | 12359 dart.defineLazyProperties(Platform, { |
| 12360 get supportsTypedData() { | 12360 get supportsTypedData() { |
| 12361 return !!window.ArrayBuffer; | 12361 return !!dart.global.ArrayBuffer; |
| 12362 } | 12362 } |
| 12363 }); | 12363 }); |
| 12364 function _wrapZone(callback) { | 12364 function _wrapZone(callback) { |
| 12365 if (dart.equals(async.Zone.current, async.Zone.ROOT)) return callback; | 12365 if (dart.equals($async.Zone.current, $async.Zone.ROOT)) return callback; |
| 12366 if (callback == null) return null; | 12366 if (callback == null) return null; |
| 12367 return async.Zone.current.bindUnaryCallback(callback, {runGuarded: true}); | 12367 return $async.Zone.current.bindUnaryCallback(callback, {runGuarded: true}); |
| 12368 } | 12368 } |
| 12369 dart.fn(_wrapZone, dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynami
c])]); | 12369 dart.fn(_wrapZone, dart.dynamic, [dart.functionType(dart.dynamic, [dart.dynami
c])]); |
| 12370 function _wrapBinaryZone(callback) { | 12370 function _wrapBinaryZone(callback) { |
| 12371 if (dart.equals(async.Zone.current, async.Zone.ROOT)) return callback; | 12371 if (dart.equals($async.Zone.current, $async.Zone.ROOT)) return callback; |
| 12372 if (callback == null) return null; | 12372 if (callback == null) return null; |
| 12373 return async.Zone.current.bindBinaryCallback(callback, {runGuarded: true}); | 12373 return $async.Zone.current.bindBinaryCallback(callback, {runGuarded: true}); |
| 12374 } | 12374 } |
| 12375 dart.fn(_wrapBinaryZone, dart.dynamic, [dart.functionType(dart.dynamic, [dart.
dynamic, dart.dynamic])]); | 12375 dart.fn(_wrapBinaryZone, dart.dynamic, [dart.functionType(dart.dynamic, [dart.
dynamic, dart.dynamic])]); |
| 12376 function query(relativeSelectors) { | 12376 function query(relativeSelectors) { |
| 12377 return exports.document.query(relativeSelectors); | 12377 return exports.document.query(relativeSelectors); |
| 12378 } | 12378 } |
| 12379 dart.fn(query, Element, [core.String]); | 12379 dart.fn(query, Element, [core.String]); |
| 12380 function queryAll(relativeSelectors) { | 12380 function queryAll(relativeSelectors) { |
| 12381 return exports.document.queryAll(relativeSelectors); | 12381 return exports.document.queryAll(relativeSelectors); |
| 12382 } | 12382 } |
| 12383 dart.fn(queryAll, ElementList$(Element), [core.String]); | 12383 dart.fn(queryAll, ElementList$(Element), [core.String]); |
| (...skipping 207 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12591 dart.setSignature(_ValidatingTreeSanitizer, { | 12591 dart.setSignature(_ValidatingTreeSanitizer, { |
| 12592 constructors: () => ({_ValidatingTreeSanitizer: [_ValidatingTreeSanitizer, [
NodeValidator]]}), | 12592 constructors: () => ({_ValidatingTreeSanitizer: [_ValidatingTreeSanitizer, [
NodeValidator]]}), |
| 12593 methods: () => ({ | 12593 methods: () => ({ |
| 12594 sanitizeTree: [dart.void, [Node]], | 12594 sanitizeTree: [dart.void, [Node]], |
| 12595 [_removeNode]: [dart.void, [Node, Node]], | 12595 [_removeNode]: [dart.void, [Node, Node]], |
| 12596 [_sanitizeUntrustedElement]: [dart.void, [dart.dynamic, Node]], | 12596 [_sanitizeUntrustedElement]: [dart.void, [dart.dynamic, Node]], |
| 12597 [_sanitizeElement]: [dart.void, [Element, Node, core.bool, core.String, co
re.String, core.Map, core.String]], | 12597 [_sanitizeElement]: [dart.void, [Element, Node, core.bool, core.String, co
re.String, core.Map, core.String]], |
| 12598 sanitizeNode: [dart.void, [Node, Node]] | 12598 sanitizeNode: [dart.void, [Node, Node]] |
| 12599 }) | 12599 }) |
| 12600 }); | 12600 }); |
| 12601 dart.defineLazyProperties(exports, { |
| 12602 get window() { |
| 12603 return dart.as(wrap_jso(dart.global), Window); |
| 12604 } |
| 12605 }); |
| 12601 dart.copyProperties(exports, { | 12606 dart.copyProperties(exports, { |
| 12602 get window() { | |
| 12603 return dart.as(wrap_jso(window), Window); | |
| 12604 }, | |
| 12605 get document() { | 12607 get document() { |
| 12606 return dart.as(wrap_jso(document), HtmlDocument); | 12608 return dart.as(wrap_jso(document), HtmlDocument); |
| 12607 } | 12609 } |
| 12608 }); | 12610 }); |
| 12609 class _EntryArray extends core.Object {} | 12611 class _EntryArray extends core.Object {} |
| 12610 _EntryArray[dart.implements] = () => [core.List$(dart.dynamic)]; | 12612 _EntryArray[dart.implements] = () => [core.List$(dart.dynamic)]; |
| 12611 _EntryArray[dart.metadata] = () => [dart.const(new _js_helper.Native("EntryArr
ay"))]; | 12613 _EntryArray[dart.metadata] = () => [dart.const(new _js_helper.Native("EntryArr
ay"))]; |
| 12612 function spawnDomUri(uri, args, message) { | 12614 function spawnDomUri(uri, args, message) { |
| 12613 dart.throw(new core.UnimplementedError()); | 12615 dart.throw(new core.UnimplementedError()); |
| 12614 } | 12616 } |
| 12615 dart.fn(spawnDomUri, async.Future$(isolate.Isolate), [core.Uri, core.List$(cor
e.String), dart.dynamic]); | 12617 dart.fn(spawnDomUri, $async.Future$(isolate.Isolate), [core.Uri, core.List$(co
re.String), dart.dynamic]); |
| 12616 const _F1 = dart.typedef('_F1', () => dart.functionType(dart.dynamic, [dart.dy
namic])); | 12618 const _F1 = dart.typedef('_F1', () => dart.functionType(dart.dynamic, [dart.dy
namic])); |
| 12617 const _wrapper = Symbol("dart_wrapper"); | 12619 const _wrapper = Symbol("dart_wrapper"); |
| 12618 function unwrap_jso(wrapped) { | 12620 function unwrap_jso(wrapped) { |
| 12619 if (dart.is(wrapped, DartHtmlDomObject)) { | 12621 if (dart.is(wrapped, DartHtmlDomObject)) { |
| 12620 return dart.dload(wrapped, 'raw'); | 12622 return dart.dload(wrapped, 'raw'); |
| 12621 } | 12623 } |
| 12622 if (dart.is(wrapped, _F1)) { | 12624 if (dart.is(wrapped, _F1)) { |
| 12623 if (wrapped.hasOwnProperty(_wrapper)) { | 12625 if (wrapped.hasOwnProperty(_wrapper)) { |
| 12624 return wrapped[_wrapper]; | 12626 return wrapped[_wrapper]; |
| 12625 } | 12627 } |
| (...skipping 174 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 12800 exports.ElementUpgrader = ElementUpgrader; | 12802 exports.ElementUpgrader = ElementUpgrader; |
| 12801 exports.NodeValidator = NodeValidator; | 12803 exports.NodeValidator = NodeValidator; |
| 12802 exports.NodeTreeSanitizer = NodeTreeSanitizer; | 12804 exports.NodeTreeSanitizer = NodeTreeSanitizer; |
| 12803 exports.UriPolicy = UriPolicy; | 12805 exports.UriPolicy = UriPolicy; |
| 12804 exports.spawnDomUri = spawnDomUri; | 12806 exports.spawnDomUri = spawnDomUri; |
| 12805 exports.unwrap_jso = unwrap_jso; | 12807 exports.unwrap_jso = unwrap_jso; |
| 12806 exports.wrap_jso = wrap_jso; | 12808 exports.wrap_jso = wrap_jso; |
| 12807 exports.createCustomUpgrader = createCustomUpgrader; | 12809 exports.createCustomUpgrader = createCustomUpgrader; |
| 12808 exports.getHtmlCreateFunction = getHtmlCreateFunction; | 12810 exports.getHtmlCreateFunction = getHtmlCreateFunction; |
| 12809 }); | 12811 }); |
| OLD | NEW |