anchor.diff:        },
         onPause: () { subscription.pause(); },
         onResume: () { subscription.resume(); },
  -      onCancel: () { subscription.cancel(); }
  +      onCancel: () { subscription.cancel(); },
  +      sync: true
       );
       return controller.stream;
     }
  
positive.code:       },
        onPause: () { subscription.pause(); },
        onResume: () { subscription.resume(); },
        onCancel: () { subscription.cancel(); }
      );
      return controller.stream;
    }
  
negative.code:   Stream asyncExpand(Stream convert(T event)) {
      StreamController controller;
      StreamSubscription subscription;
      controller = new StreamController(
        onListen: () {
          subscription = this.listen(
              (T event) {
  