anchor.diff:        expect(e, isRedirectLimitExceededException);
         expect(e.redirects.length, equals(2));
       });
  -    future.onComplete((_) {
  +    future.onComplete(expectAsync1((_) {
         print("#maxRedirects test stopping server...");
         stopServer();
         print("#maxRedirects test server stopped");
  -    });
  +    }));
   
       expect(future, completes);
       print("#maxRedirects test started");
  
positive.code:       print("#followRedirects test response received");
        expect(response.statusCode, equals(302));
      });
      future.onComplete((_) {
        print("#followRedirects test stopping server...");
        stopServer();
        print("#followRedirects test server stopped");
      });
  
      expect(future, completes);
      print("#followRedirects test started");
  
negative.code:       expect(response.statusCode, equals(200));
        return consumeInputStream(response.stream);
      }).transform((bytes) => new String.fromCharCodes(bytes));
      future.onComplete(expectAsync1((_) {
        stopServer();
      }));
  
      expect(future, completion(parse(equals({
        'method': 'POST',
  