| Index: generated/googleapis_beta/test/pubsub/v1beta2_test.dart
|
| diff --git a/generated/googleapis_beta/test/pubsub/v1beta2_test.dart b/generated/googleapis_beta/test/pubsub/v1beta2_test.dart
|
| index 7720b5484dcd7e59ce18e7bf235570f4d65cede8..9503b8c846cb83a3aa7ac586fe0b689f793dab82 100644
|
| --- a/generated/googleapis_beta/test/pubsub/v1beta2_test.dart
|
| +++ b/generated/googleapis_beta/test/pubsub/v1beta2_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_beta/pubsub/v1beta2.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);
|
| }
|
|
|
| -buildUnnamed3718() {
|
| +buildUnnamed3192() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3718(core.List<core.String> o) {
|
| +checkUnnamed3192(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 = buildUnnamed3718();
|
| + o.ackIds = buildUnnamed3192();
|
| }
|
| buildCounterAcknowledgeRequest--;
|
| return o;
|
| @@ -78,19 +78,19 @@ buildAcknowledgeRequest() {
|
| checkAcknowledgeRequest(api.AcknowledgeRequest o) {
|
| buildCounterAcknowledgeRequest++;
|
| if (buildCounterAcknowledgeRequest < 3) {
|
| - checkUnnamed3718(o.ackIds);
|
| + checkUnnamed3192(o.ackIds);
|
| }
|
| buildCounterAcknowledgeRequest--;
|
| }
|
|
|
| -buildUnnamed3719() {
|
| +buildUnnamed3193() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3719(core.List<core.String> o) {
|
| +checkUnnamed3193(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 = buildUnnamed3719();
|
| + o.members = buildUnnamed3193();
|
| o.role = "foo";
|
| }
|
| buildCounterBinding--;
|
| @@ -111,7 +111,7 @@ buildBinding() {
|
| checkBinding(api.Binding o) {
|
| buildCounterBinding++;
|
| if (buildCounterBinding < 3) {
|
| - checkUnnamed3719(o.members);
|
| + checkUnnamed3193(o.members);
|
| unittest.expect(o.role, unittest.equals('foo'));
|
| }
|
| buildCounterBinding--;
|
| @@ -134,14 +134,14 @@ checkEmpty(api.Empty o) {
|
| buildCounterEmpty--;
|
| }
|
|
|
| -buildUnnamed3720() {
|
| +buildUnnamed3194() {
|
| var o = new core.List<api.Subscription>();
|
| o.add(buildSubscription());
|
| o.add(buildSubscription());
|
| return o;
|
| }
|
|
|
| -checkUnnamed3720(core.List<api.Subscription> o) {
|
| +checkUnnamed3194(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 = buildUnnamed3720();
|
| + o.subscriptions = buildUnnamed3194();
|
| }
|
| buildCounterListSubscriptionsResponse--;
|
| return o;
|
| @@ -163,19 +163,19 @@ checkListSubscriptionsResponse(api.ListSubscriptionsResponse o) {
|
| buildCounterListSubscriptionsResponse++;
|
| if (buildCounterListSubscriptionsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed3720(o.subscriptions);
|
| + checkUnnamed3194(o.subscriptions);
|
| }
|
| buildCounterListSubscriptionsResponse--;
|
| }
|
|
|
| -buildUnnamed3721() {
|
| +buildUnnamed3195() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3721(core.List<core.String> o) {
|
| +checkUnnamed3195(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 = buildUnnamed3721();
|
| + o.subscriptions = buildUnnamed3195();
|
| }
|
| buildCounterListTopicSubscriptionsResponse--;
|
| return o;
|
| @@ -197,19 +197,19 @@ checkListTopicSubscriptionsResponse(api.ListTopicSubscriptionsResponse o) {
|
| buildCounterListTopicSubscriptionsResponse++;
|
| if (buildCounterListTopicSubscriptionsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed3721(o.subscriptions);
|
| + checkUnnamed3195(o.subscriptions);
|
| }
|
| buildCounterListTopicSubscriptionsResponse--;
|
| }
|
|
|
| -buildUnnamed3722() {
|
| +buildUnnamed3196() {
|
| var o = new core.List<api.Topic>();
|
| o.add(buildTopic());
|
| o.add(buildTopic());
|
| return o;
|
| }
|
|
|
| -checkUnnamed3722(core.List<api.Topic> o) {
|
| +checkUnnamed3196(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 = buildUnnamed3722();
|
| + o.topics = buildUnnamed3196();
|
| }
|
| buildCounterListTopicsResponse--;
|
| return o;
|
| @@ -231,19 +231,19 @@ checkListTopicsResponse(api.ListTopicsResponse o) {
|
| buildCounterListTopicsResponse++;
|
| if (buildCounterListTopicsResponse < 3) {
|
| unittest.expect(o.nextPageToken, unittest.equals('foo'));
|
| - checkUnnamed3722(o.topics);
|
| + checkUnnamed3196(o.topics);
|
| }
|
| buildCounterListTopicsResponse--;
|
| }
|
|
|
| -buildUnnamed3723() {
|
| +buildUnnamed3197() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3723(core.List<core.String> o) {
|
| +checkUnnamed3197(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'));
|
| @@ -256,7 +256,7 @@ buildModifyAckDeadlineRequest() {
|
| if (buildCounterModifyAckDeadlineRequest < 3) {
|
| o.ackDeadlineSeconds = 42;
|
| o.ackId = "foo";
|
| - o.ackIds = buildUnnamed3723();
|
| + o.ackIds = buildUnnamed3197();
|
| }
|
| buildCounterModifyAckDeadlineRequest--;
|
| return o;
|
| @@ -267,7 +267,7 @@ checkModifyAckDeadlineRequest(api.ModifyAckDeadlineRequest o) {
|
| if (buildCounterModifyAckDeadlineRequest < 3) {
|
| unittest.expect(o.ackDeadlineSeconds, unittest.equals(42));
|
| unittest.expect(o.ackId, unittest.equals('foo'));
|
| - checkUnnamed3723(o.ackIds);
|
| + checkUnnamed3197(o.ackIds);
|
| }
|
| buildCounterModifyAckDeadlineRequest--;
|
| }
|
| @@ -291,14 +291,14 @@ checkModifyPushConfigRequest(api.ModifyPushConfigRequest o) {
|
| buildCounterModifyPushConfigRequest--;
|
| }
|
|
|
| -buildUnnamed3724() {
|
| +buildUnnamed3198() {
|
| var o = new core.List<api.Binding>();
|
| o.add(buildBinding());
|
| o.add(buildBinding());
|
| return o;
|
| }
|
|
|
| -checkUnnamed3724(core.List<api.Binding> o) {
|
| +checkUnnamed3198(core.List<api.Binding> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkBinding(o[0]);
|
| checkBinding(o[1]);
|
| @@ -309,7 +309,7 @@ buildPolicy() {
|
| var o = new api.Policy();
|
| buildCounterPolicy++;
|
| if (buildCounterPolicy < 3) {
|
| - o.bindings = buildUnnamed3724();
|
| + o.bindings = buildUnnamed3198();
|
| o.etag = "foo";
|
| o.version = 42;
|
| }
|
| @@ -320,21 +320,21 @@ buildPolicy() {
|
| checkPolicy(api.Policy o) {
|
| buildCounterPolicy++;
|
| if (buildCounterPolicy < 3) {
|
| - checkUnnamed3724(o.bindings);
|
| + checkUnnamed3198(o.bindings);
|
| unittest.expect(o.etag, unittest.equals('foo'));
|
| unittest.expect(o.version, unittest.equals(42));
|
| }
|
| buildCounterPolicy--;
|
| }
|
|
|
| -buildUnnamed3725() {
|
| +buildUnnamed3199() {
|
| var o = new core.List<api.PubsubMessage>();
|
| o.add(buildPubsubMessage());
|
| o.add(buildPubsubMessage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed3725(core.List<api.PubsubMessage> o) {
|
| +checkUnnamed3199(core.List<api.PubsubMessage> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkPubsubMessage(o[0]);
|
| checkPubsubMessage(o[1]);
|
| @@ -345,7 +345,7 @@ buildPublishRequest() {
|
| var o = new api.PublishRequest();
|
| buildCounterPublishRequest++;
|
| if (buildCounterPublishRequest < 3) {
|
| - o.messages = buildUnnamed3725();
|
| + o.messages = buildUnnamed3199();
|
| }
|
| buildCounterPublishRequest--;
|
| return o;
|
| @@ -354,19 +354,19 @@ buildPublishRequest() {
|
| checkPublishRequest(api.PublishRequest o) {
|
| buildCounterPublishRequest++;
|
| if (buildCounterPublishRequest < 3) {
|
| - checkUnnamed3725(o.messages);
|
| + checkUnnamed3199(o.messages);
|
| }
|
| buildCounterPublishRequest--;
|
| }
|
|
|
| -buildUnnamed3726() {
|
| +buildUnnamed3200() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3726(core.List<core.String> o) {
|
| +checkUnnamed3200(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'));
|
| @@ -377,7 +377,7 @@ buildPublishResponse() {
|
| var o = new api.PublishResponse();
|
| buildCounterPublishResponse++;
|
| if (buildCounterPublishResponse < 3) {
|
| - o.messageIds = buildUnnamed3726();
|
| + o.messageIds = buildUnnamed3200();
|
| }
|
| buildCounterPublishResponse--;
|
| return o;
|
| @@ -386,19 +386,19 @@ buildPublishResponse() {
|
| checkPublishResponse(api.PublishResponse o) {
|
| buildCounterPublishResponse++;
|
| if (buildCounterPublishResponse < 3) {
|
| - checkUnnamed3726(o.messageIds);
|
| + checkUnnamed3200(o.messageIds);
|
| }
|
| buildCounterPublishResponse--;
|
| }
|
|
|
| -buildUnnamed3727() {
|
| +buildUnnamed3201() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed3727(core.Map<core.String, core.String> o) {
|
| +checkUnnamed3201(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'));
|
| @@ -409,7 +409,7 @@ buildPubsubMessage() {
|
| var o = new api.PubsubMessage();
|
| buildCounterPubsubMessage++;
|
| if (buildCounterPubsubMessage < 3) {
|
| - o.attributes = buildUnnamed3727();
|
| + o.attributes = buildUnnamed3201();
|
| o.data = "foo";
|
| o.messageId = "foo";
|
| o.publishTime = "foo";
|
| @@ -421,7 +421,7 @@ buildPubsubMessage() {
|
| checkPubsubMessage(api.PubsubMessage o) {
|
| buildCounterPubsubMessage++;
|
| if (buildCounterPubsubMessage < 3) {
|
| - checkUnnamed3727(o.attributes);
|
| + checkUnnamed3201(o.attributes);
|
| unittest.expect(o.data, unittest.equals('foo'));
|
| unittest.expect(o.messageId, unittest.equals('foo'));
|
| unittest.expect(o.publishTime, unittest.equals('foo'));
|
| @@ -450,14 +450,14 @@ checkPullRequest(api.PullRequest o) {
|
| buildCounterPullRequest--;
|
| }
|
|
|
| -buildUnnamed3728() {
|
| +buildUnnamed3202() {
|
| var o = new core.List<api.ReceivedMessage>();
|
| o.add(buildReceivedMessage());
|
| o.add(buildReceivedMessage());
|
| return o;
|
| }
|
|
|
| -checkUnnamed3728(core.List<api.ReceivedMessage> o) {
|
| +checkUnnamed3202(core.List<api.ReceivedMessage> o) {
|
| unittest.expect(o, unittest.hasLength(2));
|
| checkReceivedMessage(o[0]);
|
| checkReceivedMessage(o[1]);
|
| @@ -468,7 +468,7 @@ buildPullResponse() {
|
| var o = new api.PullResponse();
|
| buildCounterPullResponse++;
|
| if (buildCounterPullResponse < 3) {
|
| - o.receivedMessages = buildUnnamed3728();
|
| + o.receivedMessages = buildUnnamed3202();
|
| }
|
| buildCounterPullResponse--;
|
| return o;
|
| @@ -477,19 +477,19 @@ buildPullResponse() {
|
| checkPullResponse(api.PullResponse o) {
|
| buildCounterPullResponse++;
|
| if (buildCounterPullResponse < 3) {
|
| - checkUnnamed3728(o.receivedMessages);
|
| + checkUnnamed3202(o.receivedMessages);
|
| }
|
| buildCounterPullResponse--;
|
| }
|
|
|
| -buildUnnamed3729() {
|
| +buildUnnamed3203() {
|
| var o = new core.Map<core.String, core.String>();
|
| o["x"] = "foo";
|
| o["y"] = "foo";
|
| return o;
|
| }
|
|
|
| -checkUnnamed3729(core.Map<core.String, core.String> o) {
|
| +checkUnnamed3203(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'));
|
| @@ -500,7 +500,7 @@ buildPushConfig() {
|
| var o = new api.PushConfig();
|
| buildCounterPushConfig++;
|
| if (buildCounterPushConfig < 3) {
|
| - o.attributes = buildUnnamed3729();
|
| + o.attributes = buildUnnamed3203();
|
| o.pushEndpoint = "foo";
|
| }
|
| buildCounterPushConfig--;
|
| @@ -510,7 +510,7 @@ buildPushConfig() {
|
| checkPushConfig(api.PushConfig o) {
|
| buildCounterPushConfig++;
|
| if (buildCounterPushConfig < 3) {
|
| - checkUnnamed3729(o.attributes);
|
| + checkUnnamed3203(o.attributes);
|
| unittest.expect(o.pushEndpoint, unittest.equals('foo'));
|
| }
|
| buildCounterPushConfig--;
|
| @@ -581,14 +581,14 @@ checkSubscription(api.Subscription o) {
|
| buildCounterSubscription--;
|
| }
|
|
|
| -buildUnnamed3730() {
|
| +buildUnnamed3204() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3730(core.List<core.String> o) {
|
| +checkUnnamed3204(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'));
|
| @@ -599,7 +599,7 @@ buildTestIamPermissionsRequest() {
|
| var o = new api.TestIamPermissionsRequest();
|
| buildCounterTestIamPermissionsRequest++;
|
| if (buildCounterTestIamPermissionsRequest < 3) {
|
| - o.permissions = buildUnnamed3730();
|
| + o.permissions = buildUnnamed3204();
|
| }
|
| buildCounterTestIamPermissionsRequest--;
|
| return o;
|
| @@ -608,19 +608,19 @@ buildTestIamPermissionsRequest() {
|
| checkTestIamPermissionsRequest(api.TestIamPermissionsRequest o) {
|
| buildCounterTestIamPermissionsRequest++;
|
| if (buildCounterTestIamPermissionsRequest < 3) {
|
| - checkUnnamed3730(o.permissions);
|
| + checkUnnamed3204(o.permissions);
|
| }
|
| buildCounterTestIamPermissionsRequest--;
|
| }
|
|
|
| -buildUnnamed3731() {
|
| +buildUnnamed3205() {
|
| var o = new core.List<core.String>();
|
| o.add("foo");
|
| o.add("foo");
|
| return o;
|
| }
|
|
|
| -checkUnnamed3731(core.List<core.String> o) {
|
| +checkUnnamed3205(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'));
|
| @@ -631,7 +631,7 @@ buildTestIamPermissionsResponse() {
|
| var o = new api.TestIamPermissionsResponse();
|
| buildCounterTestIamPermissionsResponse++;
|
| if (buildCounterTestIamPermissionsResponse < 3) {
|
| - o.permissions = buildUnnamed3731();
|
| + o.permissions = buildUnnamed3205();
|
| }
|
| buildCounterTestIamPermissionsResponse--;
|
| return o;
|
| @@ -640,7 +640,7 @@ buildTestIamPermissionsResponse() {
|
| checkTestIamPermissionsResponse(api.TestIamPermissionsResponse o) {
|
| buildCounterTestIamPermissionsResponse++;
|
| if (buildCounterTestIamPermissionsResponse < 3) {
|
| - checkUnnamed3731(o.permissions);
|
| + checkUnnamed3205(o.permissions);
|
| }
|
| buildCounterTestIamPermissionsResponse--;
|
| }
|
| @@ -862,7 +862,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);
|
|
|
| @@ -900,7 +900,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);
|
| })));
|
| });
|
| @@ -911,7 +911,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);
|
|
|
| @@ -949,7 +949,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);
|
| })));
|
| });
|
| @@ -959,7 +959,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;
|
| @@ -994,7 +994,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);
|
| })));
|
| });
|
| @@ -1004,7 +1004,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;
|
| @@ -1039,7 +1039,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);
|
| })));
|
| });
|
| @@ -1049,7 +1049,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;
|
| @@ -1084,7 +1084,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);
|
| })));
|
| });
|
| @@ -1094,9 +1094,9 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsSubscriptionsResourceApi res = new api.PubsubApi(mock).projects.subscriptions;
|
| var arg_project = "foo";
|
| - var arg_pageSize = 42;
|
| var arg_pageToken = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var arg_pageSize = 42;
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1123,8 +1123,8 @@ main() {
|
| addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| }
|
| }
|
| - unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
| unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
|
| + unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
|
|
|
|
| var h = {
|
| @@ -1133,7 +1133,7 @@ main() {
|
| var resp = convert.JSON.encode(buildListSubscriptionsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.list(arg_project, pageSize: arg_pageSize, pageToken: arg_pageToken).then(unittest.expectAsync(((api.ListSubscriptionsResponse response) {
|
| + res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync1(((api.ListSubscriptionsResponse response) {
|
| checkListSubscriptionsResponse(response);
|
| })));
|
| });
|
| @@ -1144,7 +1144,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);
|
|
|
| @@ -1182,7 +1182,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);
|
| })));
|
| });
|
| @@ -1193,7 +1193,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);
|
|
|
| @@ -1231,7 +1231,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);
|
| })));
|
| });
|
| @@ -1242,7 +1242,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);
|
|
|
| @@ -1280,7 +1280,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);
|
| })));
|
| });
|
| @@ -1291,7 +1291,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);
|
|
|
| @@ -1329,7 +1329,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);
|
| })));
|
| });
|
| @@ -1340,7 +1340,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);
|
|
|
| @@ -1378,7 +1378,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);
|
| })));
|
| });
|
| @@ -1393,7 +1393,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);
|
|
|
| @@ -1431,7 +1431,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);
|
| })));
|
| });
|
| @@ -1441,7 +1441,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;
|
| @@ -1476,7 +1476,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);
|
| })));
|
| });
|
| @@ -1486,7 +1486,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;
|
| @@ -1521,7 +1521,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);
|
| })));
|
| });
|
| @@ -1531,7 +1531,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;
|
| @@ -1566,7 +1566,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);
|
| })));
|
| });
|
| @@ -1576,9 +1576,9 @@ main() {
|
| var mock = new HttpServerMock();
|
| api.ProjectsTopicsResourceApi res = new api.PubsubApi(mock).projects.topics;
|
| var arg_project = "foo";
|
| - var arg_pageSize = 42;
|
| var arg_pageToken = "foo";
|
| - mock.register(unittest.expectAsync((http.BaseRequest req, json) {
|
| + var arg_pageSize = 42;
|
| + mock.register(unittest.expectAsync2((http.BaseRequest req, json) {
|
| var path = (req.url).path;
|
| var pathOffset = 0;
|
| var index;
|
| @@ -1605,8 +1605,8 @@ main() {
|
| addQueryParam(core.Uri.decodeQueryComponent(keyvalue[0]), core.Uri.decodeQueryComponent(keyvalue[1]));
|
| }
|
| }
|
| - unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
| unittest.expect(queryMap["pageToken"].first, unittest.equals(arg_pageToken));
|
| + unittest.expect(core.int.parse(queryMap["pageSize"].first), unittest.equals(arg_pageSize));
|
|
|
|
|
| var h = {
|
| @@ -1615,7 +1615,7 @@ main() {
|
| var resp = convert.JSON.encode(buildListTopicsResponse());
|
| return new async.Future.value(stringResponse(200, h, resp));
|
| }), true);
|
| - res.list(arg_project, pageSize: arg_pageSize, pageToken: arg_pageToken).then(unittest.expectAsync(((api.ListTopicsResponse response) {
|
| + res.list(arg_project, pageToken: arg_pageToken, pageSize: arg_pageSize).then(unittest.expectAsync1(((api.ListTopicsResponse response) {
|
| checkListTopicsResponse(response);
|
| })));
|
| });
|
| @@ -1626,7 +1626,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);
|
|
|
| @@ -1664,7 +1664,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);
|
| })));
|
| });
|
| @@ -1675,7 +1675,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);
|
|
|
| @@ -1713,7 +1713,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);
|
| })));
|
| });
|
| @@ -1724,7 +1724,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);
|
|
|
| @@ -1762,7 +1762,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);
|
| })));
|
| });
|
| @@ -1778,7 +1778,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;
|
| @@ -1815,7 +1815,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);
|
| })));
|
| });
|
|
|