| OLD | NEW |
| 1 library dart.dom.indexed_db; | 1 library dart.dom.indexed_db; |
| 2 | 2 |
| 3 import 'dart:async'; | 3 import 'dart:async'; |
| 4 import 'dart:html'; | 4 import 'dart:html'; |
| 5 import 'dart:html_common'; | 5 import 'dart:html_common'; |
| 6 import 'dart:nativewrappers'; | 6 import 'dart:nativewrappers'; |
| 7 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file | 7 // Copyright (c) 2012, the Dart project authors. Please see the AUTHORS file |
| 8 // for details. All rights reserved. Use of this source code is governed by a | 8 // for details. All rights reserved. Use of this source code is governed by a |
| 9 // BSD-style license that can be found in the LICENSE file. | 9 // BSD-style license that can be found in the LICENSE file. |
| 10 | 10 |
| (...skipping 1046 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1057 */ | 1057 */ |
| 1058 static Stream<Cursor> _cursorStreamFromResult(Request request, | 1058 static Stream<Cursor> _cursorStreamFromResult(Request request, |
| 1059 bool autoAdvance) { | 1059 bool autoAdvance) { |
| 1060 // TODO: need to guarantee that the controller provides the values | 1060 // TODO: need to guarantee that the controller provides the values |
| 1061 // immediately as waiting until the next tick will cause the transaction to | 1061 // immediately as waiting until the next tick will cause the transaction to |
| 1062 // close. | 1062 // close. |
| 1063 var controller = new StreamController(); | 1063 var controller = new StreamController(); |
| 1064 | 1064 |
| 1065 request.onError.listen((e) { | 1065 request.onError.listen((e) { |
| 1066 //TODO: Report stacktrace once issue 4061 is resolved. | 1066 //TODO: Report stacktrace once issue 4061 is resolved. |
| 1067 controller.signalError(e); | 1067 controller.addError(e); |
| 1068 }); | 1068 }); |
| 1069 | 1069 |
| 1070 request.onSuccess.listen((e) { | 1070 request.onSuccess.listen((e) { |
| 1071 Cursor cursor = request.result; | 1071 Cursor cursor = request.result; |
| 1072 if (cursor == null) { | 1072 if (cursor == null) { |
| 1073 controller.close(); | 1073 controller.close(); |
| 1074 } else { | 1074 } else { |
| 1075 controller.add(cursor); | 1075 controller.add(cursor); |
| 1076 if (autoAdvance == true) { | 1076 if (autoAdvance == true) { |
| 1077 cursor.next(); | 1077 cursor.next(); |
| (...skipping 226 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1304 | 1304 |
| 1305 // WARNING: Do not edit - generated code. | 1305 // WARNING: Do not edit - generated code. |
| 1306 | 1306 |
| 1307 | 1307 |
| 1308 @DocsEditable | 1308 @DocsEditable |
| 1309 @DomName('IDBAny') | 1309 @DomName('IDBAny') |
| 1310 class _IDBAny extends NativeFieldWrapperClass1 { | 1310 class _IDBAny extends NativeFieldWrapperClass1 { |
| 1311 _IDBAny.internal(); | 1311 _IDBAny.internal(); |
| 1312 | 1312 |
| 1313 } | 1313 } |
| OLD | NEW |