| Index: test/observe_test.dart
 | 
| diff --git a/test/observe_test.dart b/test/observe_test.dart
 | 
| index 8c206ac121cc659bb1a928c7095f6b0666f04915..a262d7f908c18cf2ba2ee6f731547f3151ff057e 100644
 | 
| --- a/test/observe_test.dart
 | 
| +++ b/test/observe_test.dart
 | 
| @@ -49,11 +49,14 @@ void _tests() {
 | 
|        var maxNumIterations = dirty_check.MAX_DIRTY_CHECK_CYCLES;
 | 
|  
 | 
|        var x = new WatcherModel(0);
 | 
| -      var sub = x.changes.listen(expectAsync((_) {
 | 
| +      int called = 0;
 | 
| +      var sub = x.changes.listen((_) {
 | 
| +        called++;
 | 
|          x.value++;
 | 
| -      }, count: maxNumIterations));
 | 
| +      });
 | 
|        x.value = 1;
 | 
|        Observable.dirtyCheck();
 | 
| +      expect(called, maxNumIterations);
 | 
|        expect(x.value, maxNumIterations + 1);
 | 
|        expect(messages.length, 2);
 | 
|  
 | 
| @@ -197,13 +200,13 @@ void _observeTests(createModel(x)) {
 | 
|        expectPropertyChanges(records, 1);
 | 
|        sub.cancel();
 | 
|  
 | 
| -      scheduleMicrotask(expectAsync(() {
 | 
| +      scheduleMicrotask(() {
 | 
|          subs.add(t.changes.listen(expectAsync((records) {
 | 
|            expectPropertyChanges(records, 1);
 | 
|          })));
 | 
|          t.value = 777;
 | 
|          scheduleMicrotask(Observable.dirtyCheck);
 | 
| -      }));
 | 
| +      });
 | 
|      }));
 | 
|      t.value = 42;
 | 
|    });
 | 
| 
 |