Roll of googleapis as of 4/7/2015.

generated/googleapis_beta/test/pubsub/v1beta1_test.dart

 library googleapis_beta.pubsub.v1beta1.test;
 
 import "dart:core" as core;
 import "dart:collection" as collection;
 import "dart:async" as async;
 import "dart:convert" as convert;
 
 import 'package:http/http.dart' as http;
 import 'package:http/testing.dart' as http_testing;
 import 'package:unittest/unittest.dart' as unittest;
-import 'package:googleapis_beta/common/common.dart' as common;
-import 'package:googleapis_beta/src/common_internal.dart' as common_internal;
-import '../common/common_internal_test.dart' as common_test;
 
 import 'package:googleapis_beta/pubsub/v1beta1.dart' as api;
 
+class HttpServerMock extends http.BaseClient {
+  core.Function _callback;
+  core.bool _expectJson;
 
+  void register(core.Function callback, core.bool expectJson) {
+    _callback = callback;
+    _expectJson = expectJson;
+  }
 
-buildUnnamed1769() {
+  async.Future<http.StreamedResponse> send(http.BaseRequest request) {
+    if (_expectJson) {
+      return request.finalize()
+          .transform(convert.UTF8.decoder)
+          .join('')
+          .then((core.String jsonString) {
+        if (jsonString.isEmpty) {
+          return _callback(request, null);
+        } else {
+          return _callback(request, convert.JSON.decode(jsonString));
+        }
+      });
+    } else {
+      var stream = request.finalize();
+      if (stream == null) {
+        return _callback(request, []);
+      } else {
+        return stream.toBytes().then((data) {
+          return _callback(request, data);
+        });
+      }
+    }
+  }
+}
+
+http.StreamedResponse stringResponse(
+    core.int status, core.Map headers, core.String body) {
+  var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]);
+  return new http.StreamedResponse(stream, status, headers: headers);
+}
+
+buildUnnamed1718() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed1769(core.List<core.String> o) {
+checkUnnamed1718(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterAcknowledgeRequest = 0;
 buildAcknowledgeRequest() {
   var o = new api.AcknowledgeRequest();
   buildCounterAcknowledgeRequest++;
   if (buildCounterAcknowledgeRequest < 3) {
-    o.ackId = buildUnnamed1769();
+    o.ackId = buildUnnamed1718();
     o.subscription = "foo";
   }
   buildCounterAcknowledgeRequest--;
   return o;
 }
 
 checkAcknowledgeRequest(api.AcknowledgeRequest o) {
   buildCounterAcknowledgeRequest++;
   if (buildCounterAcknowledgeRequest < 3) {
-    checkUnnamed1769(o.ackId);
+    checkUnnamed1718(o.ackId);
     unittest.expect(o.subscription, unittest.equals('foo'));
   }
   buildCounterAcknowledgeRequest--;
 }
 
 core.int buildCounterLabel = 0;
 buildLabel() {
   var o = new api.Label();
   buildCounterLabel++;
   if (buildCounterLabel < 3) {
     o.key = "foo";
     o.numValue = "foo";
     o.strValue = "foo";
   }
   buildCounterLabel--;
   return o;
 }
 
 checkLabel(api.Label o) {
   buildCounterLabel++;
   if (buildCounterLabel < 3) {
     unittest.expect(o.key, unittest.equals('foo'));
     unittest.expect(o.numValue, unittest.equals('foo'));
     unittest.expect(o.strValue, unittest.equals('foo'));
   }
   buildCounterLabel--;
 }
 
-buildUnnamed1770() {
+buildUnnamed1719() {
   var o = new core.List<api.Subscription>();
   o.add(buildSubscription());
   o.add(buildSubscription());
   return o;
 }
 
-checkUnnamed1770(core.List<api.Subscription> o) {
+checkUnnamed1719(core.List<api.Subscription> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkSubscription(o[0]);
   checkSubscription(o[1]);
 }
 
 core.int buildCounterListSubscriptionsResponse = 0;
 buildListSubscriptionsResponse() {
   var o = new api.ListSubscriptionsResponse();
   buildCounterListSubscriptionsResponse++;
   if (buildCounterListSubscriptionsResponse < 3) {
     o.nextPageToken = "foo";
-    o.subscription = buildUnnamed1770();
+    o.subscription = buildUnnamed1719();
   }
   buildCounterListSubscriptionsResponse--;
   return o;
 }
 
 checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) {
   buildCounterListSubscriptionsResponse++;
   if (buildCounterListSubscriptionsResponse < 3) {
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
-    checkUnnamed1770(o.subscription);
+    checkUnnamed1719(o.subscription);
   }
   buildCounterListSubscriptionsResponse--;
 }
 
-buildUnnamed1771() {
+buildUnnamed1720() {
   var o = new core.List<api.Topic>();
   o.add(buildTopic());
   o.add(buildTopic());
   return o;
 }
 
-checkUnnamed1771(core.List<api.Topic> o) {
+checkUnnamed1720(core.List<api.Topic> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkTopic(o[0]);
   checkTopic(o[1]);
 }
 
 core.int buildCounterListTopicsResponse = 0;
 buildListTopicsResponse() {
   var o = new api.ListTopicsResponse();
   buildCounterListTopicsResponse++;
   if (buildCounterListTopicsResponse < 3) {
     o.nextPageToken = "foo";
-    o.topic = buildUnnamed1771();
+    o.topic = buildUnnamed1720();
   }
   buildCounterListTopicsResponse--;
   return o;
 }
 
 checkListTopicsResponse(api.ListTopicsResponse o) {
   buildCounterListTopicsResponse++;
   if (buildCounterListTopicsResponse < 3) {
     unittest.expect(o.nextPageToken, unittest.equals('foo'));
-    checkUnnamed1771(o.topic);
+    checkUnnamed1720(o.topic);
   }
   buildCounterListTopicsResponse--;
 }
 
 core.int buildCounterModifyAckDeadlineRequest = 0;
 buildModifyAckDeadlineRequest() {
   var o = new api.ModifyAckDeadlineRequest();
   buildCounterModifyAckDeadlineRequest++;
   if (buildCounterModifyAckDeadlineRequest < 3) {
     o.ackDeadlineSeconds = 42;
@@ skipping 28 matching lines @@
 
 checkModifyPushConfigRequest(api.ModifyPushConfigRequest o) {
   buildCounterModifyPushConfigRequest++;
   if (buildCounterModifyPushConfigRequest < 3) {
     checkPushConfig(o.pushConfig);
     unittest.expect(o.subscription, unittest.equals('foo'));
   }
   buildCounterModifyPushConfigRequest--;
 }
 
-buildUnnamed1772() {
+buildUnnamed1721() {
   var o = new core.List<api.PubsubMessage>();
   o.add(buildPubsubMessage());
   o.add(buildPubsubMessage());
   return o;
 }
 
-checkUnnamed1772(core.List<api.PubsubMessage> o) {
+checkUnnamed1721(core.List<api.PubsubMessage> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPubsubMessage(o[0]);
   checkPubsubMessage(o[1]);
 }
 
 core.int buildCounterPublishBatchRequest = 0;
 buildPublishBatchRequest() {
   var o = new api.PublishBatchRequest();
   buildCounterPublishBatchRequest++;
   if (buildCounterPublishBatchRequest < 3) {
-    o.messages = buildUnnamed1772();
+    o.messages = buildUnnamed1721();
     o.topic = "foo";
   }
   buildCounterPublishBatchRequest--;
   return o;
 }
 
 checkPublishBatchRequest(api.PublishBatchRequest o) {
   buildCounterPublishBatchRequest++;
   if (buildCounterPublishBatchRequest < 3) {
-    checkUnnamed1772(o.messages);
+    checkUnnamed1721(o.messages);
     unittest.expect(o.topic, unittest.equals('foo'));
   }
   buildCounterPublishBatchRequest--;
 }
 
-buildUnnamed1773() {
+buildUnnamed1722() {
   var o = new core.List<core.String>();
   o.add("foo");
   o.add("foo");
   return o;
 }
 
-checkUnnamed1773(core.List<core.String> o) {
+checkUnnamed1722(core.List<core.String> o) {
   unittest.expect(o, unittest.hasLength(2));
   unittest.expect(o[0], unittest.equals('foo'));
   unittest.expect(o[1], unittest.equals('foo'));
 }
 
 core.int buildCounterPublishBatchResponse = 0;
 buildPublishBatchResponse() {
   var o = new api.PublishBatchResponse();
   buildCounterPublishBatchResponse++;
   if (buildCounterPublishBatchResponse < 3) {
-    o.messageIds = buildUnnamed1773();
+    o.messageIds = buildUnnamed1722();
   }
   buildCounterPublishBatchResponse--;
   return o;
 }
 
 checkPublishBatchResponse(api.PublishBatchResponse o) {
   buildCounterPublishBatchResponse++;
   if (buildCounterPublishBatchResponse < 3) {
-    checkUnnamed1773(o.messageIds);
+    checkUnnamed1722(o.messageIds);
   }
   buildCounterPublishBatchResponse--;
 }
 
 core.int buildCounterPublishRequest = 0;
 buildPublishRequest() {
   var o = new api.PublishRequest();
   buildCounterPublishRequest++;
   if (buildCounterPublishRequest < 3) {
     o.message = buildPubsubMessage();
@@ skipping 30 matching lines @@
   buildCounterPubsubEvent++;
   if (buildCounterPubsubEvent < 3) {
     unittest.expect(o.deleted, unittest.isTrue);
     checkPubsubMessage(o.message);
     unittest.expect(o.subscription, unittest.equals('foo'));
     unittest.expect(o.truncated, unittest.isTrue);
   }
   buildCounterPubsubEvent--;
 }
 
-buildUnnamed1774() {
+buildUnnamed1723() {
   var o = new core.List<api.Label>();
   o.add(buildLabel());
   o.add(buildLabel());
   return o;
 }
 
-checkUnnamed1774(core.List<api.Label> o) {
+checkUnnamed1723(core.List<api.Label> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkLabel(o[0]);
   checkLabel(o[1]);
 }
 
 core.int buildCounterPubsubMessage = 0;
 buildPubsubMessage() {
   var o = new api.PubsubMessage();
   buildCounterPubsubMessage++;
   if (buildCounterPubsubMessage < 3) {
     o.data = "foo";
-    o.label = buildUnnamed1774();
+    o.label = buildUnnamed1723();
     o.messageId = "foo";
   }
   buildCounterPubsubMessage--;
   return o;
 }
 
 checkPubsubMessage(api.PubsubMessage o) {
   buildCounterPubsubMessage++;
   if (buildCounterPubsubMessage < 3) {
     unittest.expect(o.data, unittest.equals('foo'));
-    checkUnnamed1774(o.label);
+    checkUnnamed1723(o.label);
     unittest.expect(o.messageId, unittest.equals('foo'));
   }
   buildCounterPubsubMessage--;
 }
 
 core.int buildCounterPullBatchRequest = 0;
 buildPullBatchRequest() {
   var o = new api.PullBatchRequest();
   buildCounterPullBatchRequest++;
   if (buildCounterPullBatchRequest < 3) {
     o.maxEvents = 42;
     o.returnImmediately = true;
     o.subscription = "foo";
   }
   buildCounterPullBatchRequest--;
   return o;
 }
 
 checkPullBatchRequest(api.PullBatchRequest o) {
   buildCounterPullBatchRequest++;
   if (buildCounterPullBatchRequest < 3) {
     unittest.expect(o.maxEvents, unittest.equals(42));
     unittest.expect(o.returnImmediately, unittest.isTrue);
     unittest.expect(o.subscription, unittest.equals('foo'));
   }
   buildCounterPullBatchRequest--;
 }
 
-buildUnnamed1775() {
+buildUnnamed1724() {
   var o = new core.List<api.PullResponse>();
   o.add(buildPullResponse());
   o.add(buildPullResponse());
   return o;
 }
 
-checkUnnamed1775(core.List<api.PullResponse> o) {
+checkUnnamed1724(core.List<api.PullResponse> o) {
   unittest.expect(o, unittest.hasLength(2));
   checkPullResponse(o[0]);
   checkPullResponse(o[1]);
 }
 
 core.int buildCounterPullBatchResponse = 0;
 buildPullBatchResponse() {
   var o = new api.PullBatchResponse();
   buildCounterPullBatchResponse++;
   if (buildCounterPullBatchResponse < 3) {
-    o.pullResponses = buildUnnamed1775();
+    o.pullResponses = buildUnnamed1724();
   }
   buildCounterPullBatchResponse--;
   return o;
 }
 
 checkPullBatchResponse(api.PullBatchResponse o) {
   buildCounterPullBatchResponse++;
   if (buildCounterPullBatchResponse < 3) {
-    checkUnnamed1775(o.pullResponses);
+    checkUnnamed1724(o.pullResponses);
   }
   buildCounterPullBatchResponse--;
 }
 
 core.int buildCounterPullRequest = 0;
 buildPullRequest() {
   var o = new api.PullRequest();
   buildCounterPullRequest++;
   if (buildCounterPullRequest < 3) {
     o.returnImmediately = true;
@@ skipping 256 matching lines @@
       var o = buildTopic();
       var od = new api.Topic.fromJson(o.toJson());
       checkTopic(od);
     });
   });
 
 
   unittest.group("resource-SubscriptionsResourceApi", () {
     unittest.test("method--acknowledge", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildAcknowledgeRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.AcknowledgeRequest.fromJson(json);
         checkAcknowledgeRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.acknowledge(arg_request).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--create", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildSubscription();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.Subscription.fromJson(json);
         checkSubscription(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildSubscription());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.create(arg_request).then(unittest.expectAsync(((api.Subscription response) {
         checkSubscription(response);
       })));
     });
 
     unittest.test("method--delete", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_subscription = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.equals("pubsub/v1beta1/"));
@@ skipping 17 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.delete(arg_subscription).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--get", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_subscription = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.equals("pubsub/v1beta1/"));
@@ skipping 17 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildSubscription());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.get(arg_subscription).then(unittest.expectAsync(((api.Subscription response) {
         checkSubscription(response);
       })));
     });
 
     unittest.test("method--list", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_maxResults = 42;
       var arg_pageToken = "foo";
       var arg_query = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
@@ skipping 21 matching lines @@
         }
         unittest.expect(core.int.parse(queryMap["maxResults"].first), unittest.equals(arg_maxResults));
         unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
         unittest.expect(queryMap["query"].first, unittest.equals(arg_query));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildListSubscriptionsResponse());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.list(maxResults: arg_maxResults, pageToken: arg_pageToken, query: arg_query).then(unittest.expectAsync(((api.ListSubscriptionsResponse response) {
         checkListSubscriptionsResponse(response);
       })));
     });
 
     unittest.test("method--modifyAckDeadline", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildModifyAckDeadlineRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.ModifyAckDeadlineRequest.fromJson(json);
         checkModifyAckDeadlineRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.modifyAckDeadline(arg_request).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--modifyPushConfig", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildModifyPushConfigRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.ModifyPushConfigRequest.fromJson(json);
         checkModifyPushConfigRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.modifyPushConfig(arg_request).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--pull", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildPullRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.PullRequest.fromJson(json);
         checkPullRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildPullResponse());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.pull(arg_request).then(unittest.expectAsync(((api.PullResponse response) {
         checkPullResponse(response);
       })));
     });
 
     unittest.test("method--pullBatch", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.SubscriptionsResourceApi res = new api.PubsubApi(mock).subscriptions;
       var arg_request = buildPullBatchRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.PullBatchRequest.fromJson(json);
         checkPullBatchRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildPullBatchResponse());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.pullBatch(arg_request).then(unittest.expectAsync(((api.PullBatchResponse response) {
         checkPullBatchResponse(response);
       })));
     });
 
   });
 
 
   unittest.group("resource-TopicsResourceApi", () {
     unittest.test("method--create", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_request = buildTopic();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.Topic.fromJson(json);
         checkTopic(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildTopic());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.create(arg_request).then(unittest.expectAsync(((api.Topic response) {
         checkTopic(response);
       })));
     });
 
     unittest.test("method--delete", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_topic = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.equals("pubsub/v1beta1/"));
@@ skipping 17 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.delete(arg_topic).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--get", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_topic = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
         pathOffset += 1;
         unittest.expect(path.substring(pathOffset, pathOffset + 15), unittest.equals("pubsub/v1beta1/"));
@@ skipping 17 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildTopic());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.get(arg_topic).then(unittest.expectAsync(((api.Topic response) {
         checkTopic(response);
       })));
     });
 
     unittest.test("method--list", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_maxResults = 42;
       var arg_pageToken = "foo";
       var arg_query = "foo";
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
         unittest.expect(path.substring(pathOffset, pathOffset + 1), unittest.equals("/"));
@@ skipping 21 matching lines @@
         }
         unittest.expect(core.int.parse(queryMap["maxResults"].first), unittest.equals(arg_maxResults));
         unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
         unittest.expect(queryMap["query"].first, unittest.equals(arg_query));
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildListTopicsResponse());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.list(maxResults: arg_maxResults, pageToken: arg_pageToken, query: arg_query).then(unittest.expectAsync(((api.ListTopicsResponse response) {
         checkListTopicsResponse(response);
       })));
     });
 
     unittest.test("method--publish", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_request = buildPublishRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.PublishRequest.fromJson(json);
         checkPublishRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = "";
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.publish(arg_request).then(unittest.expectAsync((_) {}));
     });
 
     unittest.test("method--publishBatch", () {
 
-      var mock = new common_test.HttpServerMock();
+      var mock = new HttpServerMock();
       api.TopicsResourceApi res = new api.PubsubApi(mock).topics;
       var arg_request = buildPublishBatchRequest();
       mock.register(unittest.expectAsync((http.BaseRequest req, json) {
         var obj = new api.PublishBatchRequest.fromJson(json);
         checkPublishBatchRequest(obj);
 
         var path = (req.url).path;
         var pathOffset = 0;
         var index;
         var subPart;
@@ skipping 19 matching lines @@
             var keyvalue = part.split("=");
             addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
           }
         }
 
 
         var h = {
           "content-type" : "application/json; charset=utf-8",
         };
         var resp = convert.JSON.encode(buildPublishBatchResponse());
-        return new async.Future.value(common_test.stringResponse(200, h, resp));
+        return new async.Future.value(stringResponse(200, h, resp));
       }), true);
       res.publishBatch(arg_request).then(unittest.expectAsync(((api.PublishBatchResponse response) {
         checkPublishBatchResponse(response);
       })));
     });
 
   });
 
 
 }