anchor.diff:      // Check that we see all changes made since we started watching.
       await checkWatch(watchStream, expectedChanges);
       // Check that the empty resume marker watch also sees initial changes.
  -    await checkWatch(watchStreamWithInitialState,
  +    await checkWatch(watchStreamsWithInitialState[1],
           []..addAll(initialChanges)..addAll(expectedChanges));
     });
   
  
positive.code:     var watchStream = db.watch(table.name, prefix, resumeMarker);
  
      // Also start watching with empty resume marker.
      var watchStreamWithInitialState = db.watch(table.name, prefix);
  
      // Perform some operations after we've started watching.
      var expectedChanges = new List<WatchChange>();
  
negative.code: import 'dart:async';
  import 'dart:convert' show UTF8;
  
  import 'package:async/async.dart' show StreamSplitter;
  import 'package:test/test.dart';
  
  import 'package:syncbase/src/testing_instrumentation.dart' as testing;
  