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:             expect(hasErr, equals(false), reason : "repeated stream should not have received error");
              expect(isDone, equals(true),  reason : "repeated stream should be completed");
          });
        
        expect(future, completes);
      });
    }
  
negative.code:       controller.add(1);
        controller.addError("failed");
        controller.add(2);
  
        Future future = controller.close().then((_) => new Future.delayed(new Duration(milliseconds : 2)));
        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 ])),
  