anchor.diff:            expect(errors, equals([ "failed" ]), reason : "repeated stream should have received error only once (not repeated)");
             expect(isDone, equals(true),  reason : "repeated stream should be completed");
           });
  -      
  +
         expect(future, completes);
       });
     }
  
positive.code:       controller.add(0);
        controller.add(1);
        controller.add(2);
        
        Future future = new Future.delayed(new Duration(milliseconds : 150 * repeatCount)).then((_) => controller.close());
        future.then((_) {
              expect(list.length, equals(3 * (1 + repeatCount)), reason : "repeated [$repeatCount] stream should contain ${3 * (1 + repeatCount)} values");
              expect(list, equals(new List.generate(1 + repeatCount, (i) => i).expand((_) => [ 0, 1, 2 ])),
  
negative.code:       controller.addError("failed");
        controller.add(1);
        controller.add(2);
  
        expect(list.length, equals(1),      reason : "repeated stream should have only one event before the error");
        expect(list,        equals([ 0 ] ), reason : "repeated stream should contain the value 0");
  
        expect(error,  equals("failed"), reason : "repeated stream should have received error");
        expect(isDone, equals(true),     reason : "repeated stream should be completed");
      });
    }
  }