Skip to content

Commit 5fede56

Browse files
yoshi-automationjskeet
yoshi-automation
authored and
jskeet
committed
feat: Add method signature for Subscriber.Pull without the deprecated return_immediately field.
PiperOrigin-RevId: 383459959 Source-Author: Google APIs <noreply@google.com> Source-Date: Wed Jul 7 11:45:38 2021 -0700 Source-Repo: googleapis/googleapis Source-Sha: fe3cc5e650b8e52537f02549fe5fb49fc386f3a9 Source-Link: googleapis/googleapis@fe3cc5e
1 parent 0c9bc6d commit 5fede56

File tree

5 files changed

+331
-47
lines changed

5 files changed

+331
-47
lines changed

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Snippets/SubscriberServiceApiClientSnippets.g.cs

+62-4
Original file line numberDiff line numberDiff line change
@@ -864,7 +864,7 @@ public async Task PullRequestObjectAsync()
864864
}
865865

866866
/// <summary>Snippet for Pull</summary>
867-
public void Pull()
867+
public void Pull1()
868868
{
869869
// Snippet: Pull(string, bool, int, CallSettings)
870870
// Create client
@@ -881,7 +881,7 @@ public void Pull()
881881
}
882882

883883
/// <summary>Snippet for PullAsync</summary>
884-
public async Task PullAsync()
884+
public async Task Pull1Async()
885885
{
886886
// Snippet: PullAsync(string, bool, int, CallSettings)
887887
// Additional: PullAsync(string, bool, int, CancellationToken)
@@ -899,7 +899,7 @@ public async Task PullAsync()
899899
}
900900

901901
/// <summary>Snippet for Pull</summary>
902-
public void PullResourceNames()
902+
public void Pull1ResourceNames()
903903
{
904904
// Snippet: Pull(SubscriptionName, bool, int, CallSettings)
905905
// Create client
@@ -916,7 +916,7 @@ public void PullResourceNames()
916916
}
917917

918918
/// <summary>Snippet for PullAsync</summary>
919-
public async Task PullResourceNamesAsync()
919+
public async Task Pull1ResourceNamesAsync()
920920
{
921921
// Snippet: PullAsync(SubscriptionName, bool, int, CallSettings)
922922
// Additional: PullAsync(SubscriptionName, bool, int, CancellationToken)
@@ -933,6 +933,64 @@ public async Task PullResourceNamesAsync()
933933
// End snippet
934934
}
935935

936+
/// <summary>Snippet for Pull</summary>
937+
public void Pull2()
938+
{
939+
// Snippet: Pull(string, int, CallSettings)
940+
// Create client
941+
SubscriberServiceApiClient subscriberServiceApiClient = SubscriberServiceApiClient.Create();
942+
// Initialize request argument(s)
943+
string subscription = "projects/[PROJECT]/subscriptions/[SUBSCRIPTION]";
944+
int maxMessages = 0;
945+
// Make the request
946+
PullResponse response = subscriberServiceApiClient.Pull(subscription, maxMessages);
947+
// End snippet
948+
}
949+
950+
/// <summary>Snippet for PullAsync</summary>
951+
public async Task Pull2Async()
952+
{
953+
// Snippet: PullAsync(string, int, CallSettings)
954+
// Additional: PullAsync(string, int, CancellationToken)
955+
// Create client
956+
SubscriberServiceApiClient subscriberServiceApiClient = await SubscriberServiceApiClient.CreateAsync();
957+
// Initialize request argument(s)
958+
string subscription = "projects/[PROJECT]/subscriptions/[SUBSCRIPTION]";
959+
int maxMessages = 0;
960+
// Make the request
961+
PullResponse response = await subscriberServiceApiClient.PullAsync(subscription, maxMessages);
962+
// End snippet
963+
}
964+
965+
/// <summary>Snippet for Pull</summary>
966+
public void Pull2ResourceNames()
967+
{
968+
// Snippet: Pull(SubscriptionName, int, CallSettings)
969+
// Create client
970+
SubscriberServiceApiClient subscriberServiceApiClient = SubscriberServiceApiClient.Create();
971+
// Initialize request argument(s)
972+
SubscriptionName subscription = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]");
973+
int maxMessages = 0;
974+
// Make the request
975+
PullResponse response = subscriberServiceApiClient.Pull(subscription, maxMessages);
976+
// End snippet
977+
}
978+
979+
/// <summary>Snippet for PullAsync</summary>
980+
public async Task Pull2ResourceNamesAsync()
981+
{
982+
// Snippet: PullAsync(SubscriptionName, int, CallSettings)
983+
// Additional: PullAsync(SubscriptionName, int, CancellationToken)
984+
// Create client
985+
SubscriberServiceApiClient subscriberServiceApiClient = await SubscriberServiceApiClient.CreateAsync();
986+
// Initialize request argument(s)
987+
SubscriptionName subscription = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]");
988+
int maxMessages = 0;
989+
// Make the request
990+
PullResponse response = await subscriberServiceApiClient.PullAsync(subscription, maxMessages);
991+
// End snippet
992+
}
993+
936994
/// <summary>Snippet for StreamingPull</summary>
937995
public async Task StreamingPull()
938996
{

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1.Tests/SubscriberServiceApiClientTest.g.cs

+100-4
Original file line numberDiff line numberDiff line change
@@ -961,7 +961,7 @@ public void PullRequestObject()
961961
}
962962

963963
[xunit::FactAttribute]
964-
public void Pull()
964+
public void Pull1()
965965
{
966966
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
967967
PullRequest request = new PullRequest
@@ -989,7 +989,7 @@ public void Pull()
989989
}
990990

991991
[xunit::FactAttribute]
992-
public async stt::Task PullAsync()
992+
public async stt::Task Pull1Async()
993993
{
994994
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
995995
PullRequest request = new PullRequest
@@ -1021,7 +1021,7 @@ public void Pull()
10211021
}
10221022

10231023
[xunit::FactAttribute]
1024-
public void PullResourceNames()
1024+
public void Pull1ResourceNames()
10251025
{
10261026
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
10271027
PullRequest request = new PullRequest
@@ -1049,7 +1049,7 @@ public void PullResourceNames()
10491049
}
10501050

10511051
[xunit::FactAttribute]
1052-
public async stt::Task PullResourceNamesAsync()
1052+
public async stt::Task Pull1ResourceNamesAsync()
10531053
{
10541054
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
10551055
PullRequest request = new PullRequest
@@ -1080,6 +1080,102 @@ public void PullResourceNames()
10801080
mockGrpcClient.VerifyAll();
10811081
}
10821082

1083+
[xunit::FactAttribute]
1084+
public void Pull2()
1085+
{
1086+
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
1087+
PullRequest request = new PullRequest
1088+
{
1089+
SubscriptionAsSubscriptionName = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]"),
1090+
MaxMessages = 453182879,
1091+
};
1092+
PullResponse expectedResponse = new PullResponse
1093+
{
1094+
ReceivedMessages =
1095+
{
1096+
new ReceivedMessage(),
1097+
},
1098+
};
1099+
mockGrpcClient.Setup(x => x.Pull(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
1100+
SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
1101+
PullResponse response = client.Pull(request.Subscription, request.MaxMessages);
1102+
xunit::Assert.Same(expectedResponse, response);
1103+
mockGrpcClient.VerifyAll();
1104+
}
1105+
1106+
[xunit::FactAttribute]
1107+
public async stt::Task Pull2Async()
1108+
{
1109+
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
1110+
PullRequest request = new PullRequest
1111+
{
1112+
SubscriptionAsSubscriptionName = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]"),
1113+
MaxMessages = 453182879,
1114+
};
1115+
PullResponse expectedResponse = new PullResponse
1116+
{
1117+
ReceivedMessages =
1118+
{
1119+
new ReceivedMessage(),
1120+
},
1121+
};
1122+
mockGrpcClient.Setup(x => x.PullAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<PullResponse>(stt::Task.FromResult(expectedResponse), null, null, null, null));
1123+
SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
1124+
PullResponse responseCallSettings = await client.PullAsync(request.Subscription, request.MaxMessages, gaxgrpc::CallSettings.FromCancellationToken(st::CancellationToken.None));
1125+
xunit::Assert.Same(expectedResponse, responseCallSettings);
1126+
PullResponse responseCancellationToken = await client.PullAsync(request.Subscription, request.MaxMessages, st::CancellationToken.None);
1127+
xunit::Assert.Same(expectedResponse, responseCancellationToken);
1128+
mockGrpcClient.VerifyAll();
1129+
}
1130+
1131+
[xunit::FactAttribute]
1132+
public void Pull2ResourceNames()
1133+
{
1134+
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
1135+
PullRequest request = new PullRequest
1136+
{
1137+
SubscriptionAsSubscriptionName = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]"),
1138+
MaxMessages = 453182879,
1139+
};
1140+
PullResponse expectedResponse = new PullResponse
1141+
{
1142+
ReceivedMessages =
1143+
{
1144+
new ReceivedMessage(),
1145+
},
1146+
};
1147+
mockGrpcClient.Setup(x => x.Pull(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(expectedResponse);
1148+
SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
1149+
PullResponse response = client.Pull(request.SubscriptionAsSubscriptionName, request.MaxMessages);
1150+
xunit::Assert.Same(expectedResponse, response);
1151+
mockGrpcClient.VerifyAll();
1152+
}
1153+
1154+
[xunit::FactAttribute]
1155+
public async stt::Task Pull2ResourceNamesAsync()
1156+
{
1157+
moq::Mock<Subscriber.SubscriberClient> mockGrpcClient = new moq::Mock<Subscriber.SubscriberClient>(moq::MockBehavior.Strict);
1158+
PullRequest request = new PullRequest
1159+
{
1160+
SubscriptionAsSubscriptionName = SubscriptionName.FromProjectSubscription("[PROJECT]", "[SUBSCRIPTION]"),
1161+
MaxMessages = 453182879,
1162+
};
1163+
PullResponse expectedResponse = new PullResponse
1164+
{
1165+
ReceivedMessages =
1166+
{
1167+
new ReceivedMessage(),
1168+
},
1169+
};
1170+
mockGrpcClient.Setup(x => x.PullAsync(request, moq::It.IsAny<grpccore::CallOptions>())).Returns(new grpccore::AsyncUnaryCall<PullResponse>(stt::Task.FromResult(expectedResponse), null, null, null, null));
1171+
SubscriberServiceApiClient client = new SubscriberServiceApiClientImpl(mockGrpcClient.Object, null);
1172+
PullResponse responseCallSettings = await client.PullAsync(request.SubscriptionAsSubscriptionName, request.MaxMessages, gaxgrpc::CallSettings.FromCancellationToken(st::CancellationToken.None));
1173+
xunit::Assert.Same(expectedResponse, responseCallSettings);
1174+
PullResponse responseCancellationToken = await client.PullAsync(request.SubscriptionAsSubscriptionName, request.MaxMessages, st::CancellationToken.None);
1175+
xunit::Assert.Same(expectedResponse, responseCancellationToken);
1176+
mockGrpcClient.VerifyAll();
1177+
}
1178+
10831179
[xunit::FactAttribute]
10841180
public void ModifyPushConfigRequestObject()
10851181
{

‎apis/Google.Cloud.PubSub.V1/Google.Cloud.PubSub.V1/Pubsub.g.cs

+38-38
Original file line numberDiff line numberDiff line change
@@ -207,7 +207,7 @@ static PubsubReflection() {
207207
"c3Vic2NyaXB0aW9ucy8qfTpkZXRhY2gacMpBFXB1YnN1Yi5nb29nbGVhcGlz",
208208
"LmNvbdJBVWh0dHBzOi8vd3d3Lmdvb2dsZWFwaXMuY29tL2F1dGgvY2xvdWQt",
209209
"cGxhdGZvcm0saHR0cHM6Ly93d3cuZ29vZ2xlYXBpcy5jb20vYXV0aC9wdWJz",
210-
"dWIygxUKClN1YnNjcmliZXIStAEKEkNyZWF0ZVN1YnNjcmlwdGlvbhIeLmdv",
210+
"dWIyoBUKClN1YnNjcmliZXIStAEKEkNyZWF0ZVN1YnNjcmlwdGlvbhIeLmdv",
211211
"b2dsZS5wdWJzdWIudjEuU3Vic2NyaXB0aW9uGh4uZ29vZ2xlLnB1YnN1Yi52",
212212
"MS5TdWJzY3JpcHRpb24iXoLT5JMCKholL3YxL3tuYW1lPXByb2plY3RzLyov",
213213
"c3Vic2NyaXB0aW9ucy8qfToBKtpBK25hbWUsdG9waWMscHVzaF9jb25maWcs",
@@ -234,44 +234,44 @@ static PubsubReflection() {
234234
"ZWRnZRIkLmdvb2dsZS5wdWJzdWIudjEuQWNrbm93bGVkZ2VSZXF1ZXN0GhYu",
235235
"Z29vZ2xlLnByb3RvYnVmLkVtcHR5IluC0+STAj4iOS92MS97c3Vic2NyaXB0",
236236
"aW9uPXByb2plY3RzLyovc3Vic2NyaXB0aW9ucy8qfTphY2tub3dsZWRnZToB",
237-
"KtpBFHN1YnNjcmlwdGlvbixhY2tfaWRzErMBCgRQdWxsEh0uZ29vZ2xlLnB1",
237+
"KtpBFHN1YnNjcmlwdGlvbixhY2tfaWRzEtABCgRQdWxsEh0uZ29vZ2xlLnB1",
238238
"YnN1Yi52MS5QdWxsUmVxdWVzdBoeLmdvb2dsZS5wdWJzdWIudjEuUHVsbFJl",
239-
"c3BvbnNlImyC0+STAjciMi92MS97c3Vic2NyaXB0aW9uPXByb2plY3RzLyov",
240-
"c3Vic2NyaXB0aW9ucy8qfTpwdWxsOgEq2kEsc3Vic2NyaXB0aW9uLHJldHVy",
241-
"bl9pbW1lZGlhdGVseSxtYXhfbWVzc2FnZXMSZgoNU3RyZWFtaW5nUHVsbBIm",
242-
"Lmdvb2dsZS5wdWJzdWIudjEuU3RyZWFtaW5nUHVsbFJlcXVlc3QaJy5nb29n",
243-
"bGUucHVic3ViLnYxLlN0cmVhbWluZ1B1bGxSZXNwb25zZSIAKAEwARK7AQoQ",
244-
"TW9kaWZ5UHVzaENvbmZpZxIpLmdvb2dsZS5wdWJzdWIudjEuTW9kaWZ5UHVz",
245-
"aENvbmZpZ1JlcXVlc3QaFi5nb29nbGUucHJvdG9idWYuRW1wdHkiZILT5JMC",
246-
"QyI+L3YxL3tzdWJzY3JpcHRpb249cHJvamVjdHMvKi9zdWJzY3JpcHRpb25z",
247-
"Lyp9Om1vZGlmeVB1c2hDb25maWc6ASraQRhzdWJzY3JpcHRpb24scHVzaF9j",
248-
"b25maWcSiQEKC0dldFNuYXBzaG90EiQuZ29vZ2xlLnB1YnN1Yi52MS5HZXRT",
249-
"bmFwc2hvdFJlcXVlc3QaGi5nb29nbGUucHVic3ViLnYxLlNuYXBzaG90IjiC",
250-
"0+STAicSJS92MS97c25hcHNob3Q9cHJvamVjdHMvKi9zbmFwc2hvdHMvKn3a",
251-
"QQhzbmFwc2hvdBKWAQoNTGlzdFNuYXBzaG90cxImLmdvb2dsZS5wdWJzdWIu",
252-
"djEuTGlzdFNuYXBzaG90c1JlcXVlc3QaJy5nb29nbGUucHVic3ViLnYxLkxp",
253-
"c3RTbmFwc2hvdHNSZXNwb25zZSI0gtPkkwIkEiIvdjEve3Byb2plY3Q9cHJv",
254-
"amVjdHMvKn0vc25hcHNob3Rz2kEHcHJvamVjdBKXAQoOQ3JlYXRlU25hcHNo",
255-
"b3QSJy5nb29nbGUucHVic3ViLnYxLkNyZWF0ZVNuYXBzaG90UmVxdWVzdBoa",
256-
"Lmdvb2dsZS5wdWJzdWIudjEuU25hcHNob3QiQILT5JMCJhohL3YxL3tuYW1l",
257-
"PXByb2plY3RzLyovc25hcHNob3RzLyp9OgEq2kERbmFtZSxzdWJzY3JpcHRp",
258-
"b24SjAEKDlVwZGF0ZVNuYXBzaG90EicuZ29vZ2xlLnB1YnN1Yi52MS5VcGRh",
259-
"dGVTbmFwc2hvdFJlcXVlc3QaGi5nb29nbGUucHVic3ViLnYxLlNuYXBzaG90",
260-
"IjWC0+STAi8yKi92MS97c25hcHNob3QubmFtZT1wcm9qZWN0cy8qL3NuYXBz",
261-
"aG90cy8qfToBKhKLAQoORGVsZXRlU25hcHNob3QSJy5nb29nbGUucHVic3Vi",
262-
"LnYxLkRlbGV0ZVNuYXBzaG90UmVxdWVzdBoWLmdvb2dsZS5wcm90b2J1Zi5F",
263-
"bXB0eSI4gtPkkwInKiUvdjEve3NuYXBzaG90PXByb2plY3RzLyovc25hcHNo",
264-
"b3RzLyp92kEIc25hcHNob3QShAEKBFNlZWsSHS5nb29nbGUucHVic3ViLnYx",
265-
"LlNlZWtSZXF1ZXN0Gh4uZ29vZ2xlLnB1YnN1Yi52MS5TZWVrUmVzcG9uc2Ui",
266-
"PYLT5JMCNyIyL3YxL3tzdWJzY3JpcHRpb249cHJvamVjdHMvKi9zdWJzY3Jp",
267-
"cHRpb25zLyp9OnNlZWs6ASoacMpBFXB1YnN1Yi5nb29nbGVhcGlzLmNvbdJB",
268-
"VWh0dHBzOi8vd3d3Lmdvb2dsZWFwaXMuY29tL2F1dGgvY2xvdWQtcGxhdGZv",
269-
"cm0saHR0cHM6Ly93d3cuZ29vZ2xlYXBpcy5jb20vYXV0aC9wdWJzdWJCrgEK",
270-
"FGNvbS5nb29nbGUucHVic3ViLnYxQgtQdWJzdWJQcm90b1ABWjZnb29nbGUu",
271-
"Z29sYW5nLm9yZy9nZW5wcm90by9nb29nbGVhcGlzL3B1YnN1Yi92MTtwdWJz",
272-
"dWL4AQGqAhZHb29nbGUuQ2xvdWQuUHViU3ViLlYxygIWR29vZ2xlXENsb3Vk",
273-
"XFB1YlN1YlxWMeoCGUdvb2dsZTo6Q2xvdWQ6OlB1YlN1Yjo6VjFiBnByb3Rv",
274-
"Mw=="));
239+
"c3BvbnNlIogBgtPkkwI3IjIvdjEve3N1YnNjcmlwdGlvbj1wcm9qZWN0cy8q",
240+
"L3N1YnNjcmlwdGlvbnMvKn06cHVsbDoBKtpBLHN1YnNjcmlwdGlvbixyZXR1",
241+
"cm5faW1tZWRpYXRlbHksbWF4X21lc3NhZ2Vz2kEZc3Vic2NyaXB0aW9uLG1h",
242+
"eF9tZXNzYWdlcxJmCg1TdHJlYW1pbmdQdWxsEiYuZ29vZ2xlLnB1YnN1Yi52",
243+
"MS5TdHJlYW1pbmdQdWxsUmVxdWVzdBonLmdvb2dsZS5wdWJzdWIudjEuU3Ry",
244+
"ZWFtaW5nUHVsbFJlc3BvbnNlIgAoATABErsBChBNb2RpZnlQdXNoQ29uZmln",
245+
"EikuZ29vZ2xlLnB1YnN1Yi52MS5Nb2RpZnlQdXNoQ29uZmlnUmVxdWVzdBoW",
246+
"Lmdvb2dsZS5wcm90b2J1Zi5FbXB0eSJkgtPkkwJDIj4vdjEve3N1YnNjcmlw",
247+
"dGlvbj1wcm9qZWN0cy8qL3N1YnNjcmlwdGlvbnMvKn06bW9kaWZ5UHVzaENv",
248+
"bmZpZzoBKtpBGHN1YnNjcmlwdGlvbixwdXNoX2NvbmZpZxKJAQoLR2V0U25h",
249+
"cHNob3QSJC5nb29nbGUucHVic3ViLnYxLkdldFNuYXBzaG90UmVxdWVzdBoa",
250+
"Lmdvb2dsZS5wdWJzdWIudjEuU25hcHNob3QiOILT5JMCJxIlL3YxL3tzbmFw",
251+
"c2hvdD1wcm9qZWN0cy8qL3NuYXBzaG90cy8qfdpBCHNuYXBzaG90EpYBCg1M",
252+
"aXN0U25hcHNob3RzEiYuZ29vZ2xlLnB1YnN1Yi52MS5MaXN0U25hcHNob3Rz",
253+
"UmVxdWVzdBonLmdvb2dsZS5wdWJzdWIudjEuTGlzdFNuYXBzaG90c1Jlc3Bv",
254+
"bnNlIjSC0+STAiQSIi92MS97cHJvamVjdD1wcm9qZWN0cy8qfS9zbmFwc2hv",
255+
"dHPaQQdwcm9qZWN0EpcBCg5DcmVhdGVTbmFwc2hvdBInLmdvb2dsZS5wdWJz",
256+
"dWIudjEuQ3JlYXRlU25hcHNob3RSZXF1ZXN0GhouZ29vZ2xlLnB1YnN1Yi52",
257+
"MS5TbmFwc2hvdCJAgtPkkwImGiEvdjEve25hbWU9cHJvamVjdHMvKi9zbmFw",
258+
"c2hvdHMvKn06ASraQRFuYW1lLHN1YnNjcmlwdGlvbhKMAQoOVXBkYXRlU25h",
259+
"cHNob3QSJy5nb29nbGUucHVic3ViLnYxLlVwZGF0ZVNuYXBzaG90UmVxdWVz",
260+
"dBoaLmdvb2dsZS5wdWJzdWIudjEuU25hcHNob3QiNYLT5JMCLzIqL3YxL3tz",
261+
"bmFwc2hvdC5uYW1lPXByb2plY3RzLyovc25hcHNob3RzLyp9OgEqEosBCg5E",
262+
"ZWxldGVTbmFwc2hvdBInLmdvb2dsZS5wdWJzdWIudjEuRGVsZXRlU25hcHNo",
263+
"b3RSZXF1ZXN0GhYuZ29vZ2xlLnByb3RvYnVmLkVtcHR5IjiC0+STAicqJS92",
264+
"MS97c25hcHNob3Q9cHJvamVjdHMvKi9zbmFwc2hvdHMvKn3aQQhzbmFwc2hv",
265+
"dBKEAQoEU2VlaxIdLmdvb2dsZS5wdWJzdWIudjEuU2Vla1JlcXVlc3QaHi5n",
266+
"b29nbGUucHVic3ViLnYxLlNlZWtSZXNwb25zZSI9gtPkkwI3IjIvdjEve3N1",
267+
"YnNjcmlwdGlvbj1wcm9qZWN0cy8qL3N1YnNjcmlwdGlvbnMvKn06c2VlazoB",
268+
"KhpwykEVcHVic3ViLmdvb2dsZWFwaXMuY29t0kFVaHR0cHM6Ly93d3cuZ29v",
269+
"Z2xlYXBpcy5jb20vYXV0aC9jbG91ZC1wbGF0Zm9ybSxodHRwczovL3d3dy5n",
270+
"b29nbGVhcGlzLmNvbS9hdXRoL3B1YnN1YkKuAQoUY29tLmdvb2dsZS5wdWJz",
271+
"dWIudjFCC1B1YnN1YlByb3RvUAFaNmdvb2dsZS5nb2xhbmcub3JnL2dlbnBy",
272+
"b3RvL2dvb2dsZWFwaXMvcHVic3ViL3YxO3B1YnN1YvgBAaoCFkdvb2dsZS5D",
273+
"bG91ZC5QdWJTdWIuVjHKAhZHb29nbGVcQ2xvdWRcUHViU3ViXFYx6gIZR29v",
274+
"Z2xlOjpDbG91ZDo6UHViU3ViOjpWMWIGcHJvdG8z"));
275275
descriptor = pbr::FileDescriptor.FromGeneratedCode(descriptorData,
276276
new pbr::FileDescriptor[] { global::Google.Api.AnnotationsReflection.Descriptor, global::Google.Api.ClientReflection.Descriptor, global::Google.Api.FieldBehaviorReflection.Descriptor, global::Google.Api.ResourceReflection.Descriptor, global::Google.Protobuf.WellKnownTypes.DurationReflection.Descriptor, global::Google.Protobuf.WellKnownTypes.EmptyReflection.Descriptor, global::Google.Protobuf.WellKnownTypes.FieldMaskReflection.Descriptor, global::Google.Protobuf.WellKnownTypes.TimestampReflection.Descriptor, global::Google.Cloud.PubSub.V1.SchemaReflection.Descriptor, },
277277
new pbr::GeneratedClrTypeInfo(null, null, new pbr::GeneratedClrTypeInfo[] {

0 commit comments

Comments
 (0)