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); |
}))); |
}); |