|
25 | 25 | import com.google.api.gax.grpc.GrpcCallSettings; |
26 | 26 | import com.google.api.gax.grpc.GrpcStubCallableFactory; |
27 | 27 | import com.google.api.gax.rpc.ClientContext; |
28 | | -import com.google.api.gax.rpc.RequestParamsExtractor; |
29 | 28 | import com.google.api.gax.rpc.UnaryCallable; |
30 | 29 | import com.google.cloud.speech.v1p1beta1.CreateCustomClassRequest; |
31 | 30 | import com.google.cloud.speech.v1p1beta1.CreatePhraseSetRequest; |
|
47 | 46 | import io.grpc.MethodDescriptor; |
48 | 47 | import io.grpc.protobuf.ProtoUtils; |
49 | 48 | import java.io.IOException; |
50 | | -import java.util.Map; |
51 | 49 | import java.util.concurrent.TimeUnit; |
52 | 50 | import javax.annotation.Generated; |
53 | 51 |
|
@@ -223,132 +221,102 @@ protected GrpcAdaptationStub( |
223 | 221 | GrpcCallSettings.<CreatePhraseSetRequest, PhraseSet>newBuilder() |
224 | 222 | .setMethodDescriptor(createPhraseSetMethodDescriptor) |
225 | 223 | .setParamsExtractor( |
226 | | - new RequestParamsExtractor<CreatePhraseSetRequest>() { |
227 | | - @Override |
228 | | - public Map<String, String> extract(CreatePhraseSetRequest request) { |
229 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
230 | | - params.put("parent", String.valueOf(request.getParent())); |
231 | | - return params.build(); |
232 | | - } |
| 224 | + request -> { |
| 225 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 226 | + params.put("parent", String.valueOf(request.getParent())); |
| 227 | + return params.build(); |
233 | 228 | }) |
234 | 229 | .build(); |
235 | 230 | GrpcCallSettings<GetPhraseSetRequest, PhraseSet> getPhraseSetTransportSettings = |
236 | 231 | GrpcCallSettings.<GetPhraseSetRequest, PhraseSet>newBuilder() |
237 | 232 | .setMethodDescriptor(getPhraseSetMethodDescriptor) |
238 | 233 | .setParamsExtractor( |
239 | | - new RequestParamsExtractor<GetPhraseSetRequest>() { |
240 | | - @Override |
241 | | - public Map<String, String> extract(GetPhraseSetRequest request) { |
242 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
243 | | - params.put("name", String.valueOf(request.getName())); |
244 | | - return params.build(); |
245 | | - } |
| 234 | + request -> { |
| 235 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 236 | + params.put("name", String.valueOf(request.getName())); |
| 237 | + return params.build(); |
246 | 238 | }) |
247 | 239 | .build(); |
248 | 240 | GrpcCallSettings<ListPhraseSetRequest, ListPhraseSetResponse> listPhraseSetTransportSettings = |
249 | 241 | GrpcCallSettings.<ListPhraseSetRequest, ListPhraseSetResponse>newBuilder() |
250 | 242 | .setMethodDescriptor(listPhraseSetMethodDescriptor) |
251 | 243 | .setParamsExtractor( |
252 | | - new RequestParamsExtractor<ListPhraseSetRequest>() { |
253 | | - @Override |
254 | | - public Map<String, String> extract(ListPhraseSetRequest request) { |
255 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
256 | | - params.put("parent", String.valueOf(request.getParent())); |
257 | | - return params.build(); |
258 | | - } |
| 244 | + request -> { |
| 245 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 246 | + params.put("parent", String.valueOf(request.getParent())); |
| 247 | + return params.build(); |
259 | 248 | }) |
260 | 249 | .build(); |
261 | 250 | GrpcCallSettings<UpdatePhraseSetRequest, PhraseSet> updatePhraseSetTransportSettings = |
262 | 251 | GrpcCallSettings.<UpdatePhraseSetRequest, PhraseSet>newBuilder() |
263 | 252 | .setMethodDescriptor(updatePhraseSetMethodDescriptor) |
264 | 253 | .setParamsExtractor( |
265 | | - new RequestParamsExtractor<UpdatePhraseSetRequest>() { |
266 | | - @Override |
267 | | - public Map<String, String> extract(UpdatePhraseSetRequest request) { |
268 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
269 | | - params.put("phrase_set.name", String.valueOf(request.getPhraseSet().getName())); |
270 | | - return params.build(); |
271 | | - } |
| 254 | + request -> { |
| 255 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 256 | + params.put("phrase_set.name", String.valueOf(request.getPhraseSet().getName())); |
| 257 | + return params.build(); |
272 | 258 | }) |
273 | 259 | .build(); |
274 | 260 | GrpcCallSettings<DeletePhraseSetRequest, Empty> deletePhraseSetTransportSettings = |
275 | 261 | GrpcCallSettings.<DeletePhraseSetRequest, Empty>newBuilder() |
276 | 262 | .setMethodDescriptor(deletePhraseSetMethodDescriptor) |
277 | 263 | .setParamsExtractor( |
278 | | - new RequestParamsExtractor<DeletePhraseSetRequest>() { |
279 | | - @Override |
280 | | - public Map<String, String> extract(DeletePhraseSetRequest request) { |
281 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
282 | | - params.put("name", String.valueOf(request.getName())); |
283 | | - return params.build(); |
284 | | - } |
| 264 | + request -> { |
| 265 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 266 | + params.put("name", String.valueOf(request.getName())); |
| 267 | + return params.build(); |
285 | 268 | }) |
286 | 269 | .build(); |
287 | 270 | GrpcCallSettings<CreateCustomClassRequest, CustomClass> createCustomClassTransportSettings = |
288 | 271 | GrpcCallSettings.<CreateCustomClassRequest, CustomClass>newBuilder() |
289 | 272 | .setMethodDescriptor(createCustomClassMethodDescriptor) |
290 | 273 | .setParamsExtractor( |
291 | | - new RequestParamsExtractor<CreateCustomClassRequest>() { |
292 | | - @Override |
293 | | - public Map<String, String> extract(CreateCustomClassRequest request) { |
294 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
295 | | - params.put("parent", String.valueOf(request.getParent())); |
296 | | - return params.build(); |
297 | | - } |
| 274 | + request -> { |
| 275 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 276 | + params.put("parent", String.valueOf(request.getParent())); |
| 277 | + return params.build(); |
298 | 278 | }) |
299 | 279 | .build(); |
300 | 280 | GrpcCallSettings<GetCustomClassRequest, CustomClass> getCustomClassTransportSettings = |
301 | 281 | GrpcCallSettings.<GetCustomClassRequest, CustomClass>newBuilder() |
302 | 282 | .setMethodDescriptor(getCustomClassMethodDescriptor) |
303 | 283 | .setParamsExtractor( |
304 | | - new RequestParamsExtractor<GetCustomClassRequest>() { |
305 | | - @Override |
306 | | - public Map<String, String> extract(GetCustomClassRequest request) { |
307 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
308 | | - params.put("name", String.valueOf(request.getName())); |
309 | | - return params.build(); |
310 | | - } |
| 284 | + request -> { |
| 285 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 286 | + params.put("name", String.valueOf(request.getName())); |
| 287 | + return params.build(); |
311 | 288 | }) |
312 | 289 | .build(); |
313 | 290 | GrpcCallSettings<ListCustomClassesRequest, ListCustomClassesResponse> |
314 | 291 | listCustomClassesTransportSettings = |
315 | 292 | GrpcCallSettings.<ListCustomClassesRequest, ListCustomClassesResponse>newBuilder() |
316 | 293 | .setMethodDescriptor(listCustomClassesMethodDescriptor) |
317 | 294 | .setParamsExtractor( |
318 | | - new RequestParamsExtractor<ListCustomClassesRequest>() { |
319 | | - @Override |
320 | | - public Map<String, String> extract(ListCustomClassesRequest request) { |
321 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
322 | | - params.put("parent", String.valueOf(request.getParent())); |
323 | | - return params.build(); |
324 | | - } |
| 295 | + request -> { |
| 296 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 297 | + params.put("parent", String.valueOf(request.getParent())); |
| 298 | + return params.build(); |
325 | 299 | }) |
326 | 300 | .build(); |
327 | 301 | GrpcCallSettings<UpdateCustomClassRequest, CustomClass> updateCustomClassTransportSettings = |
328 | 302 | GrpcCallSettings.<UpdateCustomClassRequest, CustomClass>newBuilder() |
329 | 303 | .setMethodDescriptor(updateCustomClassMethodDescriptor) |
330 | 304 | .setParamsExtractor( |
331 | | - new RequestParamsExtractor<UpdateCustomClassRequest>() { |
332 | | - @Override |
333 | | - public Map<String, String> extract(UpdateCustomClassRequest request) { |
334 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
335 | | - params.put( |
336 | | - "custom_class.name", String.valueOf(request.getCustomClass().getName())); |
337 | | - return params.build(); |
338 | | - } |
| 305 | + request -> { |
| 306 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 307 | + params.put( |
| 308 | + "custom_class.name", String.valueOf(request.getCustomClass().getName())); |
| 309 | + return params.build(); |
339 | 310 | }) |
340 | 311 | .build(); |
341 | 312 | GrpcCallSettings<DeleteCustomClassRequest, Empty> deleteCustomClassTransportSettings = |
342 | 313 | GrpcCallSettings.<DeleteCustomClassRequest, Empty>newBuilder() |
343 | 314 | .setMethodDescriptor(deleteCustomClassMethodDescriptor) |
344 | 315 | .setParamsExtractor( |
345 | | - new RequestParamsExtractor<DeleteCustomClassRequest>() { |
346 | | - @Override |
347 | | - public Map<String, String> extract(DeleteCustomClassRequest request) { |
348 | | - ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
349 | | - params.put("name", String.valueOf(request.getName())); |
350 | | - return params.build(); |
351 | | - } |
| 316 | + request -> { |
| 317 | + ImmutableMap.Builder<String, String> params = ImmutableMap.builder(); |
| 318 | + params.put("name", String.valueOf(request.getName())); |
| 319 | + return params.build(); |
352 | 320 | }) |
353 | 321 | .build(); |
354 | 322 |
|
@@ -472,7 +440,13 @@ public UnaryCallable<DeleteCustomClassRequest, Empty> deleteCustomClassCallable( |
472 | 440 |
|
473 | 441 | @Override |
474 | 442 | public final void close() { |
475 | | - shutdown(); |
| 443 | + try { |
| 444 | + backgroundResources.close(); |
| 445 | + } catch (RuntimeException e) { |
| 446 | + throw e; |
| 447 | + } catch (Exception e) { |
| 448 | + throw new IllegalStateException("Failed to close resource", e); |
| 449 | + } |
476 | 450 | } |
477 | 451 |
|
478 | 452 | @Override |
|
0 commit comments