anchor.diff:        controller.addError("failed");
         controller.add(1);
         controller.add(2);
  -      
  -      Future future = controller.close();
  -      future.then((_) {
  -          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");
  -        });
  -      
  -      expect(future, completes);
  +      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");
       });
     }
   }
positive.code:           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);
      });
    }
  
negative.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);
      });
    }
  