| Index: generated/googleapis/test/pubsub/v1_test.dart
|
| diff --git a/generated/googleapis/test/pubsub/v1_test.dart b/generated/googleapis/test/pubsub/v1_test.dart
|
| index bdf0a70a1b719ec3865f0100a42ddffaf5d09d2f..b93aaee606024b30e1cf502f98163fc47b57bb28 100644
|
| --- a/generated/googleapis/test/pubsub/v1_test.dart
|
| +++ b/generated/googleapis/test/pubsub/v1_test.dart
|
| @@ -7,7 +7,7 @@ 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:test/test.dart' as unittest;
|
|
|
| import 'package:googleapis/pubsub/v1.dart' as api;
|
|
|
| @@ -46,19 +46,19 @@ class HttpServerMock extends http.BaseClient {
|
| }
|
|
|
| http.StreamedResponse stringResponse(
|
| - core.int status, core.Map headers, core.String body) {
|
| + core.int status, core.Map<core.String, core.String> headers, core.String body) {
|
| var stream = new async.Stream.fromIterable([convert.UTF8.encode(body)]);
|
| return new http.StreamedResponse(stream, status, headers: headers);
|
| }
|
|
|
| -buildUnnamed1187() {
|
| +buildUnnamed1194() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1187(core.List<core.String> o) {
|
| +checkUnnamed1194(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'));
|
| @@ -69,7 +69,7 @@ buildAcknowledgeRequest() {
|
| var o = new api.AcknowledgeRequest();
|
| buildCounterAcknowledgeRequest++;
|
| if (buildCounterAcknowledgeRequest < 3) {
|
| - o.ackIds = buildUnnamed1187();
|
| + o.ackIds = buildUnnamed1194();
|
| }
|
| buildCounterAcknowledgeRequest--;
|
| return o;
|
| @@ -78,19 +78,19 @@ buildAcknowledgeRequest() {
|
| checkAcknowledgeRequest(api.AcknowledgeRequest o) {
|
| buildCounterAcknowledgeRequest++;
|
| if (buildCounterAcknowledgeRequest < 3) {
|
| - checkUnnamed1187(o.ackIds);
|
| + checkUnnamed1194(o.ackIds);
|
| }
|
| buildCounterAcknowledgeRequest--;
|
| }
|
|
|
| -buildUnnamed1188() {
|
| +buildUnnamed1195() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1188(core.List<core.String> o) {
|
| +checkUnnamed1195(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'));
|
| @@ -101,7 +101,7 @@ buildBinding() {
|
| var o = new api.Binding();
|
| buildCounterBinding++;
|
| if (buildCounterBinding < 3) {
|
| - o.members = buildUnnamed1188();
|
| + o.members = buildUnnamed1195();
|
| o.role = "foo";
|
| }
|
| buildCounterBinding--;
|
| @@ -111,7 +111,7 @@ buildBinding() {
|
| checkBinding(api.Binding o) {
|
| buildCounterBinding++;
|
| if (buildCounterBinding < 3) {
|
| - checkUnnamed1188(o.members);
|
| + checkUnnamed1195(o.members);
|
| unittest.expect(o.role, unittest.equals('foo'));
|
| }
|
| buildCounterBinding--;
|
| @@ -134,14 +134,14 @@ checkEmpty(api.Empty o) {
|
| buildCounterEmpty--;
|
| }
|
|
|
| -buildUnnamed1189() {
|
| +buildUnnamed1196() {
|
| var o = new core.List<api.Subscription>();
|
| o.add(buildSubscription());
|
| o.add(buildSubscription());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1189(core.List<api.Subscription> o) {
|
| +checkUnnamed1196(core.List<api.Subscription> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkSubscription(o[0]);
|
| checkSubscription(o[1]);
|
| @@ -153,7 +153,7 @@ buildListSubscriptionsResponse() {
|
| buildCounterListSubscriptionsResponse++;
|
| if (buildCounterListSubscriptionsResponse < 3) {
|
| o.nextPageToken = "foo";
|
| - o.subscriptions = buildUnnamed1189();
|
| + o.subscriptions = buildUnnamed1196();
|
| }
|
| buildCounterListSubscriptionsResponse--;
|
| return o;
|
| @@ -163,19 +163,19 @@ checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) {
|
| buildCounterListSubscriptionsResponse++;
|
| if (buildCounterListSubscriptionsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed1189(o.subscriptions);
|
| + checkUnnamed1196(o.subscriptions);
|
| }
|
| buildCounterListSubscriptionsResponse--;
|
| }
|
|
|
| -buildUnnamed1190() {
|
| +buildUnnamed1197() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1190(core.List<core.String> o) {
|
| +checkUnnamed1197(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'));
|
| @@ -187,7 +187,7 @@ buildListTopicSubscriptionsResponse() {
|
| buildCounterListTopicSubscriptionsResponse++;
|
| if (buildCounterListTopicSubscriptionsResponse < 3) {
|
| o.nextPageToken = "foo";
|
| - o.subscriptions = buildUnnamed1190();
|
| + o.subscriptions = buildUnnamed1197();
|
| }
|
| buildCounterListTopicSubscriptionsResponse--;
|
| return o;
|
| @@ -197,19 +197,19 @@ checkListTopicSubscriptionsResponse(api.ListTopicSubscriptionsResponse o) {
|
| buildCounterListTopicSubscriptionsResponse++;
|
| if (buildCounterListTopicSubscriptionsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed1190(o.subscriptions);
|
| + checkUnnamed1197(o.subscriptions);
|
| }
|
| buildCounterListTopicSubscriptionsResponse--;
|
| }
|
|
|
| -buildUnnamed1191() {
|
| +buildUnnamed1198() {
|
| var o = new core.List<api.Topic>();
|
| o.add(buildTopic());
|
| o.add(buildTopic());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1191(core.List<api.Topic> o) {
|
| +checkUnnamed1198(core.List<api.Topic> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkTopic(o[0]);
|
| checkTopic(o[1]);
|
| @@ -221,7 +221,7 @@ buildListTopicsResponse() {
|
| buildCounterListTopicsResponse++;
|
| if (buildCounterListTopicsResponse < 3) {
|
| o.nextPageToken = "foo";
|
| - o.topics = buildUnnamed1191();
|
| + o.topics = buildUnnamed1198();
|
| }
|
| buildCounterListTopicsResponse--;
|
| return o;
|
| @@ -231,19 +231,19 @@ checkListTopicsResponse(api.ListTopicsResponse o) {
|
| buildCounterListTopicsResponse++;
|
| if (buildCounterListTopicsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed1191(o.topics);
|
| + checkUnnamed1198(o.topics);
|
| }
|
| buildCounterListTopicsResponse--;
|
| }
|
|
|
| -buildUnnamed1192() {
|
| +buildUnnamed1199() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1192(core.List<core.String> o) {
|
| +checkUnnamed1199(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'));
|
| @@ -255,7 +255,7 @@ buildModifyAckDeadlineRequest() {
|
| buildCounterModifyAckDeadlineRequest++;
|
| if (buildCounterModifyAckDeadlineRequest < 3) {
|
| o.ackDeadlineSeconds = 42;
|
| - o.ackIds = buildUnnamed1192();
|
| + o.ackIds = buildUnnamed1199();
|
| }
|
| buildCounterModifyAckDeadlineRequest--;
|
| return o;
|
| @@ -265,7 +265,7 @@ checkModifyAckDeadlineRequest(api.ModifyAckDeadlineRequest o) {
|
| buildCounterModifyAckDeadlineRequest++;
|
| if (buildCounterModifyAckDeadlineRequest < 3) {
|
| unittest.expect(o.ackDeadlineSeconds, unittest.equals(42));
|
| - checkUnnamed1192(o.ackIds);
|
| + checkUnnamed1199(o.ackIds);
|
| }
|
| buildCounterModifyAckDeadlineRequest--;
|
| }
|
| @@ -289,14 +289,14 @@ checkModifyPushConfigRequest(api.ModifyPushConfigRequest o) {
|
| buildCounterModifyPushConfigRequest--;
|
| }
|
|
|
| -buildUnnamed1193() {
|
| +buildUnnamed1200() {
|
| var o = new core.List<api.Binding>();
|
| o.add(buildBinding());
|
| o.add(buildBinding());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1193(core.List<api.Binding> o) {
|
| +checkUnnamed1200(core.List<api.Binding> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkBinding(o[0]);
|
| checkBinding(o[1]);
|
| @@ -307,7 +307,7 @@ buildPolicy() {
|
| var o = new api.Policy();
|
| buildCounterPolicy++;
|
| if (buildCounterPolicy < 3) {
|
| - o.bindings = buildUnnamed1193();
|
| + o.bindings = buildUnnamed1200();
|
| o.etag = "foo";
|
| o.version = 42;
|
| }
|
| @@ -318,21 +318,21 @@ buildPolicy() {
|
| checkPolicy(api.Policy o) {
|
| buildCounterPolicy++;
|
| if (buildCounterPolicy < 3) {
|
| - checkUnnamed1193(o.bindings);
|
| + checkUnnamed1200(o.bindings);
|
| unittest.expect(o.etag, unittest.equals('foo'));
|
| unittest.expect(o.version, unittest.equals(42));
|
| }
|
| buildCounterPolicy--;
|
| }
|
|
|
| -buildUnnamed1194() {
|
| +buildUnnamed1201() {
|
| var o = new core.List<api.PubsubMessage>();
|
| o.add(buildPubsubMessage());
|
| o.add(buildPubsubMessage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1194(core.List<api.PubsubMessage> o) {
|
| +checkUnnamed1201(core.List<api.PubsubMessage> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkPubsubMessage(o[0]);
|
| checkPubsubMessage(o[1]);
|
| @@ -343,7 +343,7 @@ buildPublishRequest() {
|
| var o = new api.PublishRequest();
|
| buildCounterPublishRequest++;
|
| if (buildCounterPublishRequest < 3) {
|
| - o.messages = buildUnnamed1194();
|
| + o.messages = buildUnnamed1201();
|
| }
|
| buildCounterPublishRequest--;
|
| return o;
|
| @@ -352,19 +352,19 @@ buildPublishRequest() {
|
| checkPublishRequest(api.PublishRequest o) {
|
| buildCounterPublishRequest++;
|
| if (buildCounterPublishRequest < 3) {
|
| - checkUnnamed1194(o.messages);
|
| + checkUnnamed1201(o.messages);
|
| }
|
| buildCounterPublishRequest--;
|
| }
|
|
|
| -buildUnnamed1195() {
|
| +buildUnnamed1202() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1195(core.List<core.String> o) {
|
| +checkUnnamed1202(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'));
|
| @@ -375,7 +375,7 @@ buildPublishResponse() {
|
| var o = new api.PublishResponse();
|
| buildCounterPublishResponse++;
|
| if (buildCounterPublishResponse < 3) {
|
| - o.messageIds = buildUnnamed1195();
|
| + o.messageIds = buildUnnamed1202();
|
| }
|
| buildCounterPublishResponse--;
|
| return o;
|
| @@ -384,19 +384,19 @@ buildPublishResponse() {
|
| checkPublishResponse(api.PublishResponse o) {
|
| buildCounterPublishResponse++;
|
| if (buildCounterPublishResponse < 3) {
|
| - checkUnnamed1195(o.messageIds);
|
| + checkUnnamed1202(o.messageIds);
|
| }
|
| buildCounterPublishResponse--;
|
| }
|
|
|
| -buildUnnamed1196() {
|
| +buildUnnamed1203() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed1196(core.Map<core.String, core.String> o) {
|
| +checkUnnamed1203(core.Map<core.String, core.String> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| unittest.expect(o["x"], unittest.equals('foo'));
|
| unittest.expect(o["y"], unittest.equals('foo'));
|
| @@ -407,7 +407,7 @@ buildPubsubMessage() {
|
| var o = new api.PubsubMessage();
|
| buildCounterPubsubMessage++;
|
| if (buildCounterPubsubMessage < 3) {
|
| - o.attributes = buildUnnamed1196();
|
| + o.attributes = buildUnnamed1203();
|
| o.data = "foo";
|
| o.messageId = "foo";
|
| o.publishTime = "foo";
|
| @@ -419,7 +419,7 @@ buildPubsubMessage() {
|
| checkPubsubMessage(api.PubsubMessage o) {
|
| buildCounterPubsubMessage++;
|
| if (buildCounterPubsubMessage < 3) {
|
| - checkUnnamed1196(o.attributes);
|
| + checkUnnamed1203(o.attributes);
|
| unittest.expect(o.data, unittest.equals('foo'));
|
| unittest.expect(o.messageId, unittest.equals('foo'));
|
| unittest.expect(o.publishTime, unittest.equals('foo'));
|
| @@ -448,14 +448,14 @@ checkPullRequest(api.PullRequest o) {
|
| buildCounterPullRequest--;
|
| }
|
|
|
| -buildUnnamed1197() {
|
| +buildUnnamed1204() {
|
| var o = new core.List<api.ReceivedMessage>();
|
| o.add(buildReceivedMessage());
|
| o.add(buildReceivedMessage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed1197(core.List<api.ReceivedMessage> o) {
|
| +checkUnnamed1204(core.List<api.ReceivedMessage> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkReceivedMessage(o[0]);
|
| checkReceivedMessage(o[1]);
|
| @@ -466,7 +466,7 @@ buildPullResponse() {
|
| var o = new api.PullResponse();
|
| buildCounterPullResponse++;
|
| if (buildCounterPullResponse < 3) {
|
| - o.receivedMessages = buildUnnamed1197();
|
| + o.receivedMessages = buildUnnamed1204();
|
| }
|
| buildCounterPullResponse--;
|
| return o;
|
| @@ -475,19 +475,19 @@ buildPullResponse() {
|
| checkPullResponse(api.PullResponse o) {
|
| buildCounterPullResponse++;
|
| if (buildCounterPullResponse < 3) {
|
| - checkUnnamed1197(o.receivedMessages);
|
| + checkUnnamed1204(o.receivedMessages);
|
| }
|
| buildCounterPullResponse--;
|
| }
|
|
|
| -buildUnnamed1198() {
|
| +buildUnnamed1205() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed1198(core.Map<core.String, core.String> o) {
|
| +checkUnnamed1205(core.Map<core.String, core.String> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| unittest.expect(o["x"], unittest.equals('foo'));
|
| unittest.expect(o["y"], unittest.equals('foo'));
|
| @@ -498,7 +498,7 @@ buildPushConfig() {
|
| var o = new api.PushConfig();
|
| buildCounterPushConfig++;
|
| if (buildCounterPushConfig < 3) {
|
| - o.attributes = buildUnnamed1198();
|
| + o.attributes = buildUnnamed1205();
|
| o.pushEndpoint = "foo";
|
| }
|
| buildCounterPushConfig--;
|
| @@ -508,7 +508,7 @@ buildPushConfig() {
|
| checkPushConfig(api.PushConfig o) {
|
| buildCounterPushConfig++;
|
| if (buildCounterPushConfig < 3) {
|
| - checkUnnamed1198(o.attributes);
|
| + checkUnnamed1205(o.attributes);
|
| unittest.expect(o.pushEndpoint, unittest.equals('foo'));
|
| }
|
| buildCounterPushConfig--;
|
| @@ -579,14 +579,14 @@ checkSubscription(api.Subscription o) {
|
| buildCounterSubscription--;
|
| }
|
|
|
| -buildUnnamed1199() {
|
| +buildUnnamed1206() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1199(core.List<core.String> o) {
|
| +checkUnnamed1206(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'));
|
| @@ -597,7 +597,7 @@ buildTestIamPermissionsRequest() {
|
| var o = new api.TestIamPermissionsRequest();
|
| buildCounterTestIamPermissionsRequest++;
|
| if (buildCounterTestIamPermissionsRequest < 3) {
|
| - o.permissions = buildUnnamed1199();
|
| + o.permissions = buildUnnamed1206();
|
| }
|
| buildCounterTestIamPermissionsRequest--;
|
| return o;
|
| @@ -606,19 +606,19 @@ buildTestIamPermissionsRequest() {
|
| checkTestIamPermissionsRequest(api.TestIamPermissionsRequest o) {
|
| buildCounterTestIamPermissionsRequest++;
|
| if (buildCounterTestIamPermissionsRequest < 3) {
|
| - checkUnnamed1199(o.permissions);
|
| + checkUnnamed1206(o.permissions);
|
| }
|
| buildCounterTestIamPermissionsRequest--;
|
| }
|
|
|
| -buildUnnamed1200() {
|
| +buildUnnamed1207() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed1200(core.List<core.String> o) {
|
| +checkUnnamed1207(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'));
|
| @@ -629,7 +629,7 @@ buildTestIamPermissionsResponse() {
|
| var o = new api.TestIamPermissionsResponse();
|
| buildCounterTestIamPermissionsResponse++;
|
| if (buildCounterTestIamPermissionsResponse < 3) {
|
| - o.permissions = buildUnnamed1200();
|
| + o.permissions = buildUnnamed1207();
|
| }
|
| buildCounterTestIamPermissionsResponse--;
|
| return o;
|
| @@ -638,7 +638,7 @@ buildTestIamPermissionsResponse() {
|
| checkTestIamPermissionsResponse(api.TestIamPermissionsResponse o) {
|
| buildCounterTestIamPermissionsResponse++;
|
| if (buildCounterTestIamPermissionsResponse < 3) {
|
| - checkUnnamed1200(o.permissions);
|
| + checkUnnamed1207(o.permissions);
|
| }
|
| buildCounterTestIamPermissionsResponse--;
|
| }
|
| @@ -859,7 +859,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsSnapshotsResourceApi res = new api.PubsubApi(mock).projects.snapshots;
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -894,7 +894,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.getIamPolicy(arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.getIamPolicy(arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -905,7 +905,7 @@ main() {
|
| api.ProjectsSnapshotsResourceApi res = new api.PubsubApi(mock).projects.snapshots;
|
| var arg_request = buildSetIamPolicyRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.SetIamPolicyRequest.fromJson(json);
|
| checkSetIamPolicyRequest(obj);
|
|
|
| @@ -943,7 +943,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -954,7 +954,7 @@ main() {
|
| api.ProjectsSnapshotsResourceApi res = new api.PubsubApi(mock).projects.snapshots;
|
| var arg_request = buildTestIamPermissionsRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.TestIamPermissionsRequest.fromJson(json);
|
| checkTestIamPermissionsRequest(obj);
|
|
|
| @@ -992,7 +992,7 @@ main() {
|
| var resp = convert.JSON.encode(buildTestIamPermissionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync(((api.TestIamPermissionsResponse response) {
|
| + res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync1(((api.TestIamPermissionsResponse response) {
|
| checkTestIamPermissionsResponse(response);
|
| })));
|
| });
|
| @@ -1007,7 +1007,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildAcknowledgeRequest();
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.AcknowledgeRequest.fromJson(json);
|
| checkAcknowledgeRequest(obj);
|
|
|
| @@ -1045,7 +1045,7 @@ main() {
|
| var resp = convert.JSON.encode(buildEmpty());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.acknowledge(arg_request, arg_subscription).then(unittest.expectAsync(((api.Empty response) {
|
| + res.acknowledge(arg_request, arg_subscription).then(unittest.expectAsync1(((api.Empty response) {
|
| checkEmpty(response);
|
| })));
|
| });
|
| @@ -1056,7 +1056,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildSubscription();
|
| var arg_name = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.Subscription.fromJson(json);
|
| checkSubscription(obj);
|
|
|
| @@ -1094,7 +1094,7 @@ main() {
|
| var resp = convert.JSON.encode(buildSubscription());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.create(arg_request, arg_name).then(unittest.expectAsync(((api.Subscription response) {
|
| + res.create(arg_request, arg_name).then(unittest.expectAsync1(((api.Subscription response) {
|
| checkSubscription(response);
|
| })));
|
| });
|
| @@ -1104,7 +1104,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1139,7 +1139,7 @@ main() {
|
| var resp = convert.JSON.encode(buildEmpty());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.delete(arg_subscription).then(unittest.expectAsync(((api.Empty response) {
|
| + res.delete(arg_subscription).then(unittest.expectAsync1(((api.Empty response) {
|
| checkEmpty(response);
|
| })));
|
| });
|
| @@ -1149,7 +1149,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1184,7 +1184,7 @@ main() {
|
| var resp = convert.JSON.encode(buildSubscription());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.get(arg_subscription).then(unittest.expectAsync(((api.Subscription response) {
|
| + res.get(arg_subscription).then(unittest.expectAsync1(((api.Subscription response) {
|
| checkSubscription(response);
|
| })));
|
| });
|
| @@ -1194,7 +1194,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1229,7 +1229,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.getIamPolicy(arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.getIamPolicy(arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -1241,7 +1241,7 @@ main() {
|
| var arg_project = "foo";
|
| var arg_pageToken = "foo";
|
| var arg_pageSize = 42;
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1278,7 +1278,7 @@ main() {
|
| var resp = convert.JSON.encode(buildListSubscriptionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListSubscriptionsResponse response) {
|
| + res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync1(((api.ListSubscriptionsResponse response) {
|
| checkListSubscriptionsResponse(response);
|
| })));
|
| });
|
| @@ -1289,7 +1289,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildModifyAckDeadlineRequest();
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.ModifyAckDeadlineRequest.fromJson(json);
|
| checkModifyAckDeadlineRequest(obj);
|
|
|
| @@ -1327,7 +1327,7 @@ main() {
|
| var resp = convert.JSON.encode(buildEmpty());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.modifyAckDeadline(arg_request, arg_subscription).then(unittest.expectAsync(((api.Empty response) {
|
| + res.modifyAckDeadline(arg_request, arg_subscription).then(unittest.expectAsync1(((api.Empty response) {
|
| checkEmpty(response);
|
| })));
|
| });
|
| @@ -1338,7 +1338,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildModifyPushConfigRequest();
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.ModifyPushConfigRequest.fromJson(json);
|
| checkModifyPushConfigRequest(obj);
|
|
|
| @@ -1376,7 +1376,7 @@ main() {
|
| var resp = convert.JSON.encode(buildEmpty());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.modifyPushConfig(arg_request, arg_subscription).then(unittest.expectAsync(((api.Empty response) {
|
| + res.modifyPushConfig(arg_request, arg_subscription).then(unittest.expectAsync1(((api.Empty response) {
|
| checkEmpty(response);
|
| })));
|
| });
|
| @@ -1387,7 +1387,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildPullRequest();
|
| var arg_subscription = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.PullRequest.fromJson(json);
|
| checkPullRequest(obj);
|
|
|
| @@ -1425,7 +1425,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPullResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.pull(arg_request, arg_subscription).then(unittest.expectAsync(((api.PullResponse response) {
|
| + res.pull(arg_request, arg_subscription).then(unittest.expectAsync1(((api.PullResponse response) {
|
| checkPullResponse(response);
|
| })));
|
| });
|
| @@ -1436,7 +1436,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildSetIamPolicyRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.SetIamPolicyRequest.fromJson(json);
|
| checkSetIamPolicyRequest(obj);
|
|
|
| @@ -1474,7 +1474,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -1485,7 +1485,7 @@ main() {
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_request = buildTestIamPermissionsRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.TestIamPermissionsRequest.fromJson(json);
|
| checkTestIamPermissionsRequest(obj);
|
|
|
| @@ -1523,7 +1523,7 @@ main() {
|
| var resp = convert.JSON.encode(buildTestIamPermissionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync(((api.TestIamPermissionsResponse response) {
|
| + res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync1(((api.TestIamPermissionsResponse response) {
|
| checkTestIamPermissionsResponse(response);
|
| })));
|
| });
|
| @@ -1538,7 +1538,7 @@ main() {
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_request = buildTopic();
|
| var arg_name = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.Topic.fromJson(json);
|
| checkTopic(obj);
|
|
|
| @@ -1576,7 +1576,7 @@ main() {
|
| var resp = convert.JSON.encode(buildTopic());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.create(arg_request, arg_name).then(unittest.expectAsync(((api.Topic response) {
|
| + res.create(arg_request, arg_name).then(unittest.expectAsync1(((api.Topic response) {
|
| checkTopic(response);
|
| })));
|
| });
|
| @@ -1586,7 +1586,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_topic = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1621,7 +1621,7 @@ main() {
|
| var resp = convert.JSON.encode(buildEmpty());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.delete(arg_topic).then(unittest.expectAsync(((api.Empty response) {
|
| + res.delete(arg_topic).then(unittest.expectAsync1(((api.Empty response) {
|
| checkEmpty(response);
|
| })));
|
| });
|
| @@ -1631,7 +1631,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_topic = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1666,7 +1666,7 @@ main() {
|
| var resp = convert.JSON.encode(buildTopic());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.get(arg_topic).then(unittest.expectAsync(((api.Topic response) {
|
| + res.get(arg_topic).then(unittest.expectAsync1(((api.Topic response) {
|
| checkTopic(response);
|
| })));
|
| });
|
| @@ -1676,7 +1676,7 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1711,7 +1711,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.getIamPolicy(arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.getIamPolicy(arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -1723,7 +1723,7 @@ main() {
|
| var arg_project = "foo";
|
| var arg_pageToken = "foo";
|
| var arg_pageSize = 42;
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1760,7 +1760,7 @@ main() {
|
| var resp = convert.JSON.encode(buildListTopicsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListTopicsResponse response) {
|
| + res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync1(((api.ListTopicsResponse response) {
|
| checkListTopicsResponse(response);
|
| })));
|
| });
|
| @@ -1771,7 +1771,7 @@ main() {
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_request = buildPublishRequest();
|
| var arg_topic = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.PublishRequest.fromJson(json);
|
| checkPublishRequest(obj);
|
|
|
| @@ -1809,7 +1809,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPublishResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.publish(arg_request, arg_topic).then(unittest.expectAsync(((api.PublishResponse response) {
|
| + res.publish(arg_request, arg_topic).then(unittest.expectAsync1(((api.PublishResponse response) {
|
| checkPublishResponse(response);
|
| })));
|
| });
|
| @@ -1820,7 +1820,7 @@ main() {
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_request = buildSetIamPolicyRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.SetIamPolicyRequest.fromJson(json);
|
| checkSetIamPolicyRequest(obj);
|
|
|
| @@ -1858,7 +1858,7 @@ main() {
|
| var resp = convert.JSON.encode(buildPolicy());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync(((api.Policy response) {
|
| + res.setIamPolicy(arg_request, arg_resource).then(unittest.expectAsync1(((api.Policy response) {
|
| checkPolicy(response);
|
| })));
|
| });
|
| @@ -1869,7 +1869,7 @@ main() {
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_request = buildTestIamPermissionsRequest();
|
| var arg_resource = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var obj = new api.TestIamPermissionsRequest.fromJson(json);
|
| checkTestIamPermissionsRequest(obj);
|
|
|
| @@ -1907,7 +1907,7 @@ main() {
|
| var resp = convert.JSON.encode(buildTestIamPermissionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync(((api.TestIamPermissionsResponse response) {
|
| + res.testIamPermissions(arg_request, arg_resource).then(unittest.expectAsync1(((api.TestIamPermissionsResponse response) {
|
| checkTestIamPermissionsResponse(response);
|
| })));
|
| });
|
| @@ -1923,7 +1923,7 @@ main() {
|
| var arg_topic = "foo";
|
| var arg_pageToken = "foo";
|
| var arg_pageSize = 42;
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1960,7 +1960,7 @@ main() {
|
| var resp = convert.JSON.encode(buildListTopicSubscriptionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.list(arg_topic, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync(((api.ListTopicSubscriptionsResponse response) {
|
| + res.list(arg_topic, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync1(((api.ListTopicSubscriptionsResponse response) {
|
| checkListTopicSubscriptionsResponse(response);
|
| })));
|
| });
|
|
|