Converting tests over to using event streams.

tests/html/indexeddb_2_test.dart

 library IndexedDB1Test;
 import '../../pkg/unittest/lib/unittest.dart';
 import '../../pkg/unittest/lib/html_config.dart';
 import 'dart:html' as html;
 import 'dart:indexed_db' as idb;
 import 'dart:collection';
 import 'utils.dart';
 
 // Write and re-read Maps: simple Maps; Maps with DAGs; Maps with cycles.
 
@@ skipping 14 matching lines @@
   }
 
   createObjectStore(db) {
     var store = db.createObjectStore(storeName);
     expect(store, isNotNull);
   }
 
   step2(e) {
     var transaction = db.transaction(storeName, 'readonly');
     var request = transaction.objectStore(storeName).getObject(key);
-    request.on.success.add(expectAsync1((e) {
+    request.onSuccess.listen(expectAsync1((e) {
       var object = e.target.result;
       db.close();
       check(value, object);
     }));
-    request.on.error.add(fail);
+    request.onError.listen(fail);
   }
 
   step1() {
     var transaction = db.transaction([storeName], 'readwrite');
     var request = transaction.objectStore(storeName).put(value, key);
-    request.on.success.add(expectAsync1(step2));
-    request.on.error.add(fail);
+    request.onSuccess.listen(expectAsync1(step2));
+    request.onError.listen(fail);
   }
 
   initDb(e) {
     db = e.target.result;
     if (version != db.version) {
       // Legacy 'setVersion' upgrade protocol.
       var request = db.setVersion('$version');
-      request.on.success.add(
+      request.onSuccess.listen(
         expectAsync1((e) {
           createObjectStore(db);
           var transaction = e.target.result;
-          transaction.on.complete.add(expectAsync1((e) => step1()));
-          transaction.on.error.add(fail);
+          transaction.onComplete.listen(expectAsync1((e) => step1()));
+          transaction.onError.listen(fail);
         })
       );
-      request.on.error.add(fail);
+      request.onError.listen(fail);
     } else {
       step1();
     }
   }
 
   openDb(e) {
     var request = html.window.indexedDB.open(dbName, version);
     expect(request, isNotNull);
-    request.on.success.add(expectAsync1(initDb));
-    request.on.error.add(fail);
+    request.onSuccess.listen(expectAsync1(initDb));
+    request.onError.listen(fail);
     if (request is idb.OpenDBRequest) {
       // New upgrade protocol.  Old API has no 'upgradeNeeded' and uses
       // setVersion instead.
-      request.on.upgradeNeeded.add((e) {
+      request.onUpgradeNeeded.listen((e) {
           guardAsync(() {
               createObjectStore(e.target.result);
             });
         });
     }
   }
 
   // Delete any existing DB.
   var deleteRequest = html.window.indexedDB.deleteDatabase(dbName);
-  deleteRequest.on.success.add(expectAsync1(openDb));
-  deleteRequest.on.error.add(fail);
+  deleteRequest.onSuccess.listen(expectAsync1(openDb));
+  deleteRequest.onError.listen(fail);
 };
 
 
 main() {
   useHtmlConfiguration();
 
   var obj1 = {'a': 100, 'b': 's'};
   var obj2 = {'x': obj1, 'y': obj1};  // DAG.
 
   var obj3 = {};
@@ skipping 30 matching lines @@
     go('test_DAG', obj2);
     go('test_cycle', obj3);
     go('test_simple_splay', obj4);
     go('const_array_1', const [const [1], const [2]]);
     go('const_array_dag', const [const [1], const [1]]);
     go('array_deferred_copy', [1,2,3, obj3, obj3, 6]);
     go('array_deferred_copy_2', [1,2,3, [4, 5, obj3], [obj3, 6]]);
     go('cyclic_list', cyclic_list);
   }
 }