1 package com.google.showcase.v1beta1; 2 3 import static io.grpc.MethodDescriptor.generateFullMethodName; 4 5 /** 6 */ 7 @javax.annotation.Generated( 8 value = "by gRPC proto compiler", 9 comments = "Source: schema/google/showcase/v1beta1/echo.proto") 10 @io.grpc.stub.annotations.GrpcGenerated 11 public final class EchoGrpc { 12 EchoGrpc()13 private EchoGrpc() {} 14 15 public static final String SERVICE_NAME = "google.showcase.v1beta1.Echo"; 16 17 // Static method descriptors that strictly reflect the proto. 18 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, 19 com.google.showcase.v1beta1.EchoResponse> getEchoMethod; 20 21 @io.grpc.stub.annotations.RpcMethod( 22 fullMethodName = SERVICE_NAME + '/' + "Echo", 23 requestType = com.google.showcase.v1beta1.EchoRequest.class, 24 responseType = com.google.showcase.v1beta1.EchoResponse.class, 25 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 26 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, getEchoMethod()27 com.google.showcase.v1beta1.EchoResponse> getEchoMethod() { 28 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse> getEchoMethod; 29 if ((getEchoMethod = EchoGrpc.getEchoMethod) == null) { 30 synchronized (EchoGrpc.class) { 31 if ((getEchoMethod = EchoGrpc.getEchoMethod) == null) { 32 EchoGrpc.getEchoMethod = getEchoMethod = 33 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse>newBuilder() 34 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 35 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Echo")) 36 .setSampledToLocalTracing(true) 37 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 38 com.google.showcase.v1beta1.EchoRequest.getDefaultInstance())) 39 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 40 com.google.showcase.v1beta1.EchoResponse.getDefaultInstance())) 41 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Echo")) 42 .build(); 43 } 44 } 45 } 46 return getEchoMethod; 47 } 48 49 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.ExpandRequest, 50 com.google.showcase.v1beta1.EchoResponse> getExpandMethod; 51 52 @io.grpc.stub.annotations.RpcMethod( 53 fullMethodName = SERVICE_NAME + '/' + "Expand", 54 requestType = com.google.showcase.v1beta1.ExpandRequest.class, 55 responseType = com.google.showcase.v1beta1.EchoResponse.class, 56 methodType = io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) 57 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.ExpandRequest, getExpandMethod()58 com.google.showcase.v1beta1.EchoResponse> getExpandMethod() { 59 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.ExpandRequest, com.google.showcase.v1beta1.EchoResponse> getExpandMethod; 60 if ((getExpandMethod = EchoGrpc.getExpandMethod) == null) { 61 synchronized (EchoGrpc.class) { 62 if ((getExpandMethod = EchoGrpc.getExpandMethod) == null) { 63 EchoGrpc.getExpandMethod = getExpandMethod = 64 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.ExpandRequest, com.google.showcase.v1beta1.EchoResponse>newBuilder() 65 .setType(io.grpc.MethodDescriptor.MethodType.SERVER_STREAMING) 66 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Expand")) 67 .setSampledToLocalTracing(true) 68 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 69 com.google.showcase.v1beta1.ExpandRequest.getDefaultInstance())) 70 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 71 com.google.showcase.v1beta1.EchoResponse.getDefaultInstance())) 72 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Expand")) 73 .build(); 74 } 75 } 76 } 77 return getExpandMethod; 78 } 79 80 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, 81 com.google.showcase.v1beta1.EchoResponse> getCollectMethod; 82 83 @io.grpc.stub.annotations.RpcMethod( 84 fullMethodName = SERVICE_NAME + '/' + "Collect", 85 requestType = com.google.showcase.v1beta1.EchoRequest.class, 86 responseType = com.google.showcase.v1beta1.EchoResponse.class, 87 methodType = io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) 88 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, getCollectMethod()89 com.google.showcase.v1beta1.EchoResponse> getCollectMethod() { 90 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse> getCollectMethod; 91 if ((getCollectMethod = EchoGrpc.getCollectMethod) == null) { 92 synchronized (EchoGrpc.class) { 93 if ((getCollectMethod = EchoGrpc.getCollectMethod) == null) { 94 EchoGrpc.getCollectMethod = getCollectMethod = 95 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse>newBuilder() 96 .setType(io.grpc.MethodDescriptor.MethodType.CLIENT_STREAMING) 97 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Collect")) 98 .setSampledToLocalTracing(true) 99 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 100 com.google.showcase.v1beta1.EchoRequest.getDefaultInstance())) 101 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 102 com.google.showcase.v1beta1.EchoResponse.getDefaultInstance())) 103 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Collect")) 104 .build(); 105 } 106 } 107 } 108 return getCollectMethod; 109 } 110 111 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, 112 com.google.showcase.v1beta1.EchoResponse> getChatMethod; 113 114 @io.grpc.stub.annotations.RpcMethod( 115 fullMethodName = SERVICE_NAME + '/' + "Chat", 116 requestType = com.google.showcase.v1beta1.EchoRequest.class, 117 responseType = com.google.showcase.v1beta1.EchoResponse.class, 118 methodType = io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) 119 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, getChatMethod()120 com.google.showcase.v1beta1.EchoResponse> getChatMethod() { 121 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse> getChatMethod; 122 if ((getChatMethod = EchoGrpc.getChatMethod) == null) { 123 synchronized (EchoGrpc.class) { 124 if ((getChatMethod = EchoGrpc.getChatMethod) == null) { 125 EchoGrpc.getChatMethod = getChatMethod = 126 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.EchoRequest, com.google.showcase.v1beta1.EchoResponse>newBuilder() 127 .setType(io.grpc.MethodDescriptor.MethodType.BIDI_STREAMING) 128 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Chat")) 129 .setSampledToLocalTracing(true) 130 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 131 com.google.showcase.v1beta1.EchoRequest.getDefaultInstance())) 132 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 133 com.google.showcase.v1beta1.EchoResponse.getDefaultInstance())) 134 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Chat")) 135 .build(); 136 } 137 } 138 } 139 return getChatMethod; 140 } 141 142 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, 143 com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandMethod; 144 145 @io.grpc.stub.annotations.RpcMethod( 146 fullMethodName = SERVICE_NAME + '/' + "PagedExpand", 147 requestType = com.google.showcase.v1beta1.PagedExpandRequest.class, 148 responseType = com.google.showcase.v1beta1.PagedExpandResponse.class, 149 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 150 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, getPagedExpandMethod()151 com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandMethod() { 152 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandMethod; 153 if ((getPagedExpandMethod = EchoGrpc.getPagedExpandMethod) == null) { 154 synchronized (EchoGrpc.class) { 155 if ((getPagedExpandMethod = EchoGrpc.getPagedExpandMethod) == null) { 156 EchoGrpc.getPagedExpandMethod = getPagedExpandMethod = 157 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.PagedExpandRequest, com.google.showcase.v1beta1.PagedExpandResponse>newBuilder() 158 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 159 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "PagedExpand")) 160 .setSampledToLocalTracing(true) 161 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 162 com.google.showcase.v1beta1.PagedExpandRequest.getDefaultInstance())) 163 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 164 com.google.showcase.v1beta1.PagedExpandResponse.getDefaultInstance())) 165 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("PagedExpand")) 166 .build(); 167 } 168 } 169 } 170 return getPagedExpandMethod; 171 } 172 173 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandLegacyRequest, 174 com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandLegacyMethod; 175 176 @io.grpc.stub.annotations.RpcMethod( 177 fullMethodName = SERVICE_NAME + '/' + "PagedExpandLegacy", 178 requestType = com.google.showcase.v1beta1.PagedExpandLegacyRequest.class, 179 responseType = com.google.showcase.v1beta1.PagedExpandResponse.class, 180 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 181 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandLegacyRequest, getPagedExpandLegacyMethod()182 com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandLegacyMethod() { 183 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandLegacyRequest, com.google.showcase.v1beta1.PagedExpandResponse> getPagedExpandLegacyMethod; 184 if ((getPagedExpandLegacyMethod = EchoGrpc.getPagedExpandLegacyMethod) == null) { 185 synchronized (EchoGrpc.class) { 186 if ((getPagedExpandLegacyMethod = EchoGrpc.getPagedExpandLegacyMethod) == null) { 187 EchoGrpc.getPagedExpandLegacyMethod = getPagedExpandLegacyMethod = 188 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.PagedExpandLegacyRequest, com.google.showcase.v1beta1.PagedExpandResponse>newBuilder() 189 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 190 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "PagedExpandLegacy")) 191 .setSampledToLocalTracing(true) 192 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 193 com.google.showcase.v1beta1.PagedExpandLegacyRequest.getDefaultInstance())) 194 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 195 com.google.showcase.v1beta1.PagedExpandResponse.getDefaultInstance())) 196 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("PagedExpandLegacy")) 197 .build(); 198 } 199 } 200 } 201 return getPagedExpandLegacyMethod; 202 } 203 204 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, 205 com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> getPagedExpandLegacyMappedMethod; 206 207 @io.grpc.stub.annotations.RpcMethod( 208 fullMethodName = SERVICE_NAME + '/' + "PagedExpandLegacyMapped", 209 requestType = com.google.showcase.v1beta1.PagedExpandRequest.class, 210 responseType = com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse.class, 211 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 212 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, getPagedExpandLegacyMappedMethod()213 com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> getPagedExpandLegacyMappedMethod() { 214 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.PagedExpandRequest, com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> getPagedExpandLegacyMappedMethod; 215 if ((getPagedExpandLegacyMappedMethod = EchoGrpc.getPagedExpandLegacyMappedMethod) == null) { 216 synchronized (EchoGrpc.class) { 217 if ((getPagedExpandLegacyMappedMethod = EchoGrpc.getPagedExpandLegacyMappedMethod) == null) { 218 EchoGrpc.getPagedExpandLegacyMappedMethod = getPagedExpandLegacyMappedMethod = 219 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.PagedExpandRequest, com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse>newBuilder() 220 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 221 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "PagedExpandLegacyMapped")) 222 .setSampledToLocalTracing(true) 223 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 224 com.google.showcase.v1beta1.PagedExpandRequest.getDefaultInstance())) 225 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 226 com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse.getDefaultInstance())) 227 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("PagedExpandLegacyMapped")) 228 .build(); 229 } 230 } 231 } 232 return getPagedExpandLegacyMappedMethod; 233 } 234 235 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.WaitRequest, 236 com.google.longrunning.Operation> getWaitMethod; 237 238 @io.grpc.stub.annotations.RpcMethod( 239 fullMethodName = SERVICE_NAME + '/' + "Wait", 240 requestType = com.google.showcase.v1beta1.WaitRequest.class, 241 responseType = com.google.longrunning.Operation.class, 242 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 243 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.WaitRequest, getWaitMethod()244 com.google.longrunning.Operation> getWaitMethod() { 245 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.WaitRequest, com.google.longrunning.Operation> getWaitMethod; 246 if ((getWaitMethod = EchoGrpc.getWaitMethod) == null) { 247 synchronized (EchoGrpc.class) { 248 if ((getWaitMethod = EchoGrpc.getWaitMethod) == null) { 249 EchoGrpc.getWaitMethod = getWaitMethod = 250 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.WaitRequest, com.google.longrunning.Operation>newBuilder() 251 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 252 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Wait")) 253 .setSampledToLocalTracing(true) 254 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 255 com.google.showcase.v1beta1.WaitRequest.getDefaultInstance())) 256 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 257 com.google.longrunning.Operation.getDefaultInstance())) 258 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Wait")) 259 .build(); 260 } 261 } 262 } 263 return getWaitMethod; 264 } 265 266 private static volatile io.grpc.MethodDescriptor<com.google.showcase.v1beta1.BlockRequest, 267 com.google.showcase.v1beta1.BlockResponse> getBlockMethod; 268 269 @io.grpc.stub.annotations.RpcMethod( 270 fullMethodName = SERVICE_NAME + '/' + "Block", 271 requestType = com.google.showcase.v1beta1.BlockRequest.class, 272 responseType = com.google.showcase.v1beta1.BlockResponse.class, 273 methodType = io.grpc.MethodDescriptor.MethodType.UNARY) 274 public static io.grpc.MethodDescriptor<com.google.showcase.v1beta1.BlockRequest, getBlockMethod()275 com.google.showcase.v1beta1.BlockResponse> getBlockMethod() { 276 io.grpc.MethodDescriptor<com.google.showcase.v1beta1.BlockRequest, com.google.showcase.v1beta1.BlockResponse> getBlockMethod; 277 if ((getBlockMethod = EchoGrpc.getBlockMethod) == null) { 278 synchronized (EchoGrpc.class) { 279 if ((getBlockMethod = EchoGrpc.getBlockMethod) == null) { 280 EchoGrpc.getBlockMethod = getBlockMethod = 281 io.grpc.MethodDescriptor.<com.google.showcase.v1beta1.BlockRequest, com.google.showcase.v1beta1.BlockResponse>newBuilder() 282 .setType(io.grpc.MethodDescriptor.MethodType.UNARY) 283 .setFullMethodName(generateFullMethodName(SERVICE_NAME, "Block")) 284 .setSampledToLocalTracing(true) 285 .setRequestMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 286 com.google.showcase.v1beta1.BlockRequest.getDefaultInstance())) 287 .setResponseMarshaller(io.grpc.protobuf.ProtoUtils.marshaller( 288 com.google.showcase.v1beta1.BlockResponse.getDefaultInstance())) 289 .setSchemaDescriptor(new EchoMethodDescriptorSupplier("Block")) 290 .build(); 291 } 292 } 293 } 294 return getBlockMethod; 295 } 296 297 /** 298 * Creates a new async stub that supports all call types for the service 299 */ newStub(io.grpc.Channel channel)300 public static EchoStub newStub(io.grpc.Channel channel) { 301 io.grpc.stub.AbstractStub.StubFactory<EchoStub> factory = 302 new io.grpc.stub.AbstractStub.StubFactory<EchoStub>() { 303 @java.lang.Override 304 public EchoStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 305 return new EchoStub(channel, callOptions); 306 } 307 }; 308 return EchoStub.newStub(factory, channel); 309 } 310 311 /** 312 * Creates a new blocking-style stub that supports unary and streaming output calls on the service 313 */ newBlockingStub( io.grpc.Channel channel)314 public static EchoBlockingStub newBlockingStub( 315 io.grpc.Channel channel) { 316 io.grpc.stub.AbstractStub.StubFactory<EchoBlockingStub> factory = 317 new io.grpc.stub.AbstractStub.StubFactory<EchoBlockingStub>() { 318 @java.lang.Override 319 public EchoBlockingStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 320 return new EchoBlockingStub(channel, callOptions); 321 } 322 }; 323 return EchoBlockingStub.newStub(factory, channel); 324 } 325 326 /** 327 * Creates a new ListenableFuture-style stub that supports unary calls on the service 328 */ newFutureStub( io.grpc.Channel channel)329 public static EchoFutureStub newFutureStub( 330 io.grpc.Channel channel) { 331 io.grpc.stub.AbstractStub.StubFactory<EchoFutureStub> factory = 332 new io.grpc.stub.AbstractStub.StubFactory<EchoFutureStub>() { 333 @java.lang.Override 334 public EchoFutureStub newStub(io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 335 return new EchoFutureStub(channel, callOptions); 336 } 337 }; 338 return EchoFutureStub.newStub(factory, channel); 339 } 340 341 /** 342 */ 343 public interface AsyncService { 344 345 /** 346 */ echo(com.google.showcase.v1beta1.EchoRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)347 default void echo(com.google.showcase.v1beta1.EchoRequest request, 348 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 349 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getEchoMethod(), responseObserver); 350 } 351 352 /** 353 */ expand(com.google.showcase.v1beta1.ExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)354 default void expand(com.google.showcase.v1beta1.ExpandRequest request, 355 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 356 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getExpandMethod(), responseObserver); 357 } 358 359 /** 360 */ collect( io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)361 default io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoRequest> collect( 362 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 363 return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getCollectMethod(), responseObserver); 364 } 365 366 /** 367 */ chat( io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)368 default io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoRequest> chat( 369 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 370 return io.grpc.stub.ServerCalls.asyncUnimplementedStreamingCall(getChatMethod(), responseObserver); 371 } 372 373 /** 374 */ pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver)375 default void pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request, 376 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver) { 377 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPagedExpandMethod(), responseObserver); 378 } 379 380 /** 381 */ pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver)382 default void pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request, 383 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver) { 384 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPagedExpandLegacyMethod(), responseObserver); 385 } 386 387 /** 388 */ pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> responseObserver)389 default void pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request, 390 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> responseObserver) { 391 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getPagedExpandLegacyMappedMethod(), responseObserver); 392 } 393 394 /** 395 */ wait(com.google.showcase.v1beta1.WaitRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)396 default void wait(com.google.showcase.v1beta1.WaitRequest request, 397 io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) { 398 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getWaitMethod(), responseObserver); 399 } 400 401 /** 402 */ block(com.google.showcase.v1beta1.BlockRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.BlockResponse> responseObserver)403 default void block(com.google.showcase.v1beta1.BlockRequest request, 404 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.BlockResponse> responseObserver) { 405 io.grpc.stub.ServerCalls.asyncUnimplementedUnaryCall(getBlockMethod(), responseObserver); 406 } 407 } 408 409 /** 410 * Base class for the server implementation of the service Echo. 411 */ 412 public static abstract class EchoImplBase 413 implements io.grpc.BindableService, AsyncService { 414 bindService()415 @java.lang.Override public final io.grpc.ServerServiceDefinition bindService() { 416 return EchoGrpc.bindService(this); 417 } 418 } 419 420 /** 421 * A stub to allow clients to do asynchronous rpc calls to service Echo. 422 */ 423 public static final class EchoStub 424 extends io.grpc.stub.AbstractAsyncStub<EchoStub> { EchoStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions)425 private EchoStub( 426 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 427 super(channel, callOptions); 428 } 429 430 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)431 protected EchoStub build( 432 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 433 return new EchoStub(channel, callOptions); 434 } 435 436 /** 437 */ echo(com.google.showcase.v1beta1.EchoRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)438 public void echo(com.google.showcase.v1beta1.EchoRequest request, 439 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 440 io.grpc.stub.ClientCalls.asyncUnaryCall( 441 getChannel().newCall(getEchoMethod(), getCallOptions()), request, responseObserver); 442 } 443 444 /** 445 */ expand(com.google.showcase.v1beta1.ExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)446 public void expand(com.google.showcase.v1beta1.ExpandRequest request, 447 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 448 io.grpc.stub.ClientCalls.asyncServerStreamingCall( 449 getChannel().newCall(getExpandMethod(), getCallOptions()), request, responseObserver); 450 } 451 452 /** 453 */ collect( io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)454 public io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoRequest> collect( 455 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 456 return io.grpc.stub.ClientCalls.asyncClientStreamingCall( 457 getChannel().newCall(getCollectMethod(), getCallOptions()), responseObserver); 458 } 459 460 /** 461 */ chat( io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver)462 public io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoRequest> chat( 463 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse> responseObserver) { 464 return io.grpc.stub.ClientCalls.asyncBidiStreamingCall( 465 getChannel().newCall(getChatMethod(), getCallOptions()), responseObserver); 466 } 467 468 /** 469 */ pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver)470 public void pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request, 471 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver) { 472 io.grpc.stub.ClientCalls.asyncUnaryCall( 473 getChannel().newCall(getPagedExpandMethod(), getCallOptions()), request, responseObserver); 474 } 475 476 /** 477 */ pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver)478 public void pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request, 479 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse> responseObserver) { 480 io.grpc.stub.ClientCalls.asyncUnaryCall( 481 getChannel().newCall(getPagedExpandLegacyMethod(), getCallOptions()), request, responseObserver); 482 } 483 484 /** 485 */ pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> responseObserver)486 public void pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request, 487 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> responseObserver) { 488 io.grpc.stub.ClientCalls.asyncUnaryCall( 489 getChannel().newCall(getPagedExpandLegacyMappedMethod(), getCallOptions()), request, responseObserver); 490 } 491 492 /** 493 */ wait(com.google.showcase.v1beta1.WaitRequest request, io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver)494 public void wait(com.google.showcase.v1beta1.WaitRequest request, 495 io.grpc.stub.StreamObserver<com.google.longrunning.Operation> responseObserver) { 496 io.grpc.stub.ClientCalls.asyncUnaryCall( 497 getChannel().newCall(getWaitMethod(), getCallOptions()), request, responseObserver); 498 } 499 500 /** 501 */ block(com.google.showcase.v1beta1.BlockRequest request, io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.BlockResponse> responseObserver)502 public void block(com.google.showcase.v1beta1.BlockRequest request, 503 io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.BlockResponse> responseObserver) { 504 io.grpc.stub.ClientCalls.asyncUnaryCall( 505 getChannel().newCall(getBlockMethod(), getCallOptions()), request, responseObserver); 506 } 507 } 508 509 /** 510 * A stub to allow clients to do synchronous rpc calls to service Echo. 511 */ 512 public static final class EchoBlockingStub 513 extends io.grpc.stub.AbstractBlockingStub<EchoBlockingStub> { EchoBlockingStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions)514 private EchoBlockingStub( 515 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 516 super(channel, callOptions); 517 } 518 519 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)520 protected EchoBlockingStub build( 521 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 522 return new EchoBlockingStub(channel, callOptions); 523 } 524 525 /** 526 */ echo(com.google.showcase.v1beta1.EchoRequest request)527 public com.google.showcase.v1beta1.EchoResponse echo(com.google.showcase.v1beta1.EchoRequest request) { 528 return io.grpc.stub.ClientCalls.blockingUnaryCall( 529 getChannel(), getEchoMethod(), getCallOptions(), request); 530 } 531 532 /** 533 */ expand( com.google.showcase.v1beta1.ExpandRequest request)534 public java.util.Iterator<com.google.showcase.v1beta1.EchoResponse> expand( 535 com.google.showcase.v1beta1.ExpandRequest request) { 536 return io.grpc.stub.ClientCalls.blockingServerStreamingCall( 537 getChannel(), getExpandMethod(), getCallOptions(), request); 538 } 539 540 /** 541 */ pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request)542 public com.google.showcase.v1beta1.PagedExpandResponse pagedExpand(com.google.showcase.v1beta1.PagedExpandRequest request) { 543 return io.grpc.stub.ClientCalls.blockingUnaryCall( 544 getChannel(), getPagedExpandMethod(), getCallOptions(), request); 545 } 546 547 /** 548 */ pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request)549 public com.google.showcase.v1beta1.PagedExpandResponse pagedExpandLegacy(com.google.showcase.v1beta1.PagedExpandLegacyRequest request) { 550 return io.grpc.stub.ClientCalls.blockingUnaryCall( 551 getChannel(), getPagedExpandLegacyMethod(), getCallOptions(), request); 552 } 553 554 /** 555 */ pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request)556 public com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse pagedExpandLegacyMapped(com.google.showcase.v1beta1.PagedExpandRequest request) { 557 return io.grpc.stub.ClientCalls.blockingUnaryCall( 558 getChannel(), getPagedExpandLegacyMappedMethod(), getCallOptions(), request); 559 } 560 561 /** 562 */ wait(com.google.showcase.v1beta1.WaitRequest request)563 public com.google.longrunning.Operation wait(com.google.showcase.v1beta1.WaitRequest request) { 564 return io.grpc.stub.ClientCalls.blockingUnaryCall( 565 getChannel(), getWaitMethod(), getCallOptions(), request); 566 } 567 568 /** 569 */ block(com.google.showcase.v1beta1.BlockRequest request)570 public com.google.showcase.v1beta1.BlockResponse block(com.google.showcase.v1beta1.BlockRequest request) { 571 return io.grpc.stub.ClientCalls.blockingUnaryCall( 572 getChannel(), getBlockMethod(), getCallOptions(), request); 573 } 574 } 575 576 /** 577 * A stub to allow clients to do ListenableFuture-style rpc calls to service Echo. 578 */ 579 public static final class EchoFutureStub 580 extends io.grpc.stub.AbstractFutureStub<EchoFutureStub> { EchoFutureStub( io.grpc.Channel channel, io.grpc.CallOptions callOptions)581 private EchoFutureStub( 582 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 583 super(channel, callOptions); 584 } 585 586 @java.lang.Override build( io.grpc.Channel channel, io.grpc.CallOptions callOptions)587 protected EchoFutureStub build( 588 io.grpc.Channel channel, io.grpc.CallOptions callOptions) { 589 return new EchoFutureStub(channel, callOptions); 590 } 591 592 /** 593 */ echo( com.google.showcase.v1beta1.EchoRequest request)594 public com.google.common.util.concurrent.ListenableFuture<com.google.showcase.v1beta1.EchoResponse> echo( 595 com.google.showcase.v1beta1.EchoRequest request) { 596 return io.grpc.stub.ClientCalls.futureUnaryCall( 597 getChannel().newCall(getEchoMethod(), getCallOptions()), request); 598 } 599 600 /** 601 */ pagedExpand( com.google.showcase.v1beta1.PagedExpandRequest request)602 public com.google.common.util.concurrent.ListenableFuture<com.google.showcase.v1beta1.PagedExpandResponse> pagedExpand( 603 com.google.showcase.v1beta1.PagedExpandRequest request) { 604 return io.grpc.stub.ClientCalls.futureUnaryCall( 605 getChannel().newCall(getPagedExpandMethod(), getCallOptions()), request); 606 } 607 608 /** 609 */ pagedExpandLegacy( com.google.showcase.v1beta1.PagedExpandLegacyRequest request)610 public com.google.common.util.concurrent.ListenableFuture<com.google.showcase.v1beta1.PagedExpandResponse> pagedExpandLegacy( 611 com.google.showcase.v1beta1.PagedExpandLegacyRequest request) { 612 return io.grpc.stub.ClientCalls.futureUnaryCall( 613 getChannel().newCall(getPagedExpandLegacyMethod(), getCallOptions()), request); 614 } 615 616 /** 617 */ pagedExpandLegacyMapped( com.google.showcase.v1beta1.PagedExpandRequest request)618 public com.google.common.util.concurrent.ListenableFuture<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse> pagedExpandLegacyMapped( 619 com.google.showcase.v1beta1.PagedExpandRequest request) { 620 return io.grpc.stub.ClientCalls.futureUnaryCall( 621 getChannel().newCall(getPagedExpandLegacyMappedMethod(), getCallOptions()), request); 622 } 623 624 /** 625 */ wait( com.google.showcase.v1beta1.WaitRequest request)626 public com.google.common.util.concurrent.ListenableFuture<com.google.longrunning.Operation> wait( 627 com.google.showcase.v1beta1.WaitRequest request) { 628 return io.grpc.stub.ClientCalls.futureUnaryCall( 629 getChannel().newCall(getWaitMethod(), getCallOptions()), request); 630 } 631 632 /** 633 */ block( com.google.showcase.v1beta1.BlockRequest request)634 public com.google.common.util.concurrent.ListenableFuture<com.google.showcase.v1beta1.BlockResponse> block( 635 com.google.showcase.v1beta1.BlockRequest request) { 636 return io.grpc.stub.ClientCalls.futureUnaryCall( 637 getChannel().newCall(getBlockMethod(), getCallOptions()), request); 638 } 639 } 640 641 private static final int METHODID_ECHO = 0; 642 private static final int METHODID_EXPAND = 1; 643 private static final int METHODID_PAGED_EXPAND = 2; 644 private static final int METHODID_PAGED_EXPAND_LEGACY = 3; 645 private static final int METHODID_PAGED_EXPAND_LEGACY_MAPPED = 4; 646 private static final int METHODID_WAIT = 5; 647 private static final int METHODID_BLOCK = 6; 648 private static final int METHODID_COLLECT = 7; 649 private static final int METHODID_CHAT = 8; 650 651 private static final class MethodHandlers<Req, Resp> implements 652 io.grpc.stub.ServerCalls.UnaryMethod<Req, Resp>, 653 io.grpc.stub.ServerCalls.ServerStreamingMethod<Req, Resp>, 654 io.grpc.stub.ServerCalls.ClientStreamingMethod<Req, Resp>, 655 io.grpc.stub.ServerCalls.BidiStreamingMethod<Req, Resp> { 656 private final AsyncService serviceImpl; 657 private final int methodId; 658 MethodHandlers(AsyncService serviceImpl, int methodId)659 MethodHandlers(AsyncService serviceImpl, int methodId) { 660 this.serviceImpl = serviceImpl; 661 this.methodId = methodId; 662 } 663 664 @java.lang.Override 665 @java.lang.SuppressWarnings("unchecked") invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver)666 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { 667 switch (methodId) { 668 case METHODID_ECHO: 669 serviceImpl.echo((com.google.showcase.v1beta1.EchoRequest) request, 670 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse>) responseObserver); 671 break; 672 case METHODID_EXPAND: 673 serviceImpl.expand((com.google.showcase.v1beta1.ExpandRequest) request, 674 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse>) responseObserver); 675 break; 676 case METHODID_PAGED_EXPAND: 677 serviceImpl.pagedExpand((com.google.showcase.v1beta1.PagedExpandRequest) request, 678 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse>) responseObserver); 679 break; 680 case METHODID_PAGED_EXPAND_LEGACY: 681 serviceImpl.pagedExpandLegacy((com.google.showcase.v1beta1.PagedExpandLegacyRequest) request, 682 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandResponse>) responseObserver); 683 break; 684 case METHODID_PAGED_EXPAND_LEGACY_MAPPED: 685 serviceImpl.pagedExpandLegacyMapped((com.google.showcase.v1beta1.PagedExpandRequest) request, 686 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse>) responseObserver); 687 break; 688 case METHODID_WAIT: 689 serviceImpl.wait((com.google.showcase.v1beta1.WaitRequest) request, 690 (io.grpc.stub.StreamObserver<com.google.longrunning.Operation>) responseObserver); 691 break; 692 case METHODID_BLOCK: 693 serviceImpl.block((com.google.showcase.v1beta1.BlockRequest) request, 694 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.BlockResponse>) responseObserver); 695 break; 696 default: 697 throw new AssertionError(); 698 } 699 } 700 701 @java.lang.Override 702 @java.lang.SuppressWarnings("unchecked") invoke( io.grpc.stub.StreamObserver<Resp> responseObserver)703 public io.grpc.stub.StreamObserver<Req> invoke( 704 io.grpc.stub.StreamObserver<Resp> responseObserver) { 705 switch (methodId) { 706 case METHODID_COLLECT: 707 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.collect( 708 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse>) responseObserver); 709 case METHODID_CHAT: 710 return (io.grpc.stub.StreamObserver<Req>) serviceImpl.chat( 711 (io.grpc.stub.StreamObserver<com.google.showcase.v1beta1.EchoResponse>) responseObserver); 712 default: 713 throw new AssertionError(); 714 } 715 } 716 } 717 bindService(AsyncService service)718 public static final io.grpc.ServerServiceDefinition bindService(AsyncService service) { 719 return io.grpc.ServerServiceDefinition.builder(getServiceDescriptor()) 720 .addMethod( 721 getEchoMethod(), 722 io.grpc.stub.ServerCalls.asyncUnaryCall( 723 new MethodHandlers< 724 com.google.showcase.v1beta1.EchoRequest, 725 com.google.showcase.v1beta1.EchoResponse>( 726 service, METHODID_ECHO))) 727 .addMethod( 728 getExpandMethod(), 729 io.grpc.stub.ServerCalls.asyncServerStreamingCall( 730 new MethodHandlers< 731 com.google.showcase.v1beta1.ExpandRequest, 732 com.google.showcase.v1beta1.EchoResponse>( 733 service, METHODID_EXPAND))) 734 .addMethod( 735 getCollectMethod(), 736 io.grpc.stub.ServerCalls.asyncClientStreamingCall( 737 new MethodHandlers< 738 com.google.showcase.v1beta1.EchoRequest, 739 com.google.showcase.v1beta1.EchoResponse>( 740 service, METHODID_COLLECT))) 741 .addMethod( 742 getChatMethod(), 743 io.grpc.stub.ServerCalls.asyncBidiStreamingCall( 744 new MethodHandlers< 745 com.google.showcase.v1beta1.EchoRequest, 746 com.google.showcase.v1beta1.EchoResponse>( 747 service, METHODID_CHAT))) 748 .addMethod( 749 getPagedExpandMethod(), 750 io.grpc.stub.ServerCalls.asyncUnaryCall( 751 new MethodHandlers< 752 com.google.showcase.v1beta1.PagedExpandRequest, 753 com.google.showcase.v1beta1.PagedExpandResponse>( 754 service, METHODID_PAGED_EXPAND))) 755 .addMethod( 756 getPagedExpandLegacyMethod(), 757 io.grpc.stub.ServerCalls.asyncUnaryCall( 758 new MethodHandlers< 759 com.google.showcase.v1beta1.PagedExpandLegacyRequest, 760 com.google.showcase.v1beta1.PagedExpandResponse>( 761 service, METHODID_PAGED_EXPAND_LEGACY))) 762 .addMethod( 763 getPagedExpandLegacyMappedMethod(), 764 io.grpc.stub.ServerCalls.asyncUnaryCall( 765 new MethodHandlers< 766 com.google.showcase.v1beta1.PagedExpandRequest, 767 com.google.showcase.v1beta1.PagedExpandLegacyMappedResponse>( 768 service, METHODID_PAGED_EXPAND_LEGACY_MAPPED))) 769 .addMethod( 770 getWaitMethod(), 771 io.grpc.stub.ServerCalls.asyncUnaryCall( 772 new MethodHandlers< 773 com.google.showcase.v1beta1.WaitRequest, 774 com.google.longrunning.Operation>( 775 service, METHODID_WAIT))) 776 .addMethod( 777 getBlockMethod(), 778 io.grpc.stub.ServerCalls.asyncUnaryCall( 779 new MethodHandlers< 780 com.google.showcase.v1beta1.BlockRequest, 781 com.google.showcase.v1beta1.BlockResponse>( 782 service, METHODID_BLOCK))) 783 .build(); 784 } 785 786 private static abstract class EchoBaseDescriptorSupplier 787 implements io.grpc.protobuf.ProtoFileDescriptorSupplier, io.grpc.protobuf.ProtoServiceDescriptorSupplier { EchoBaseDescriptorSupplier()788 EchoBaseDescriptorSupplier() {} 789 790 @java.lang.Override getFileDescriptor()791 public com.google.protobuf.Descriptors.FileDescriptor getFileDescriptor() { 792 return com.google.showcase.v1beta1.EchoOuterClass.getDescriptor(); 793 } 794 795 @java.lang.Override getServiceDescriptor()796 public com.google.protobuf.Descriptors.ServiceDescriptor getServiceDescriptor() { 797 return getFileDescriptor().findServiceByName("Echo"); 798 } 799 } 800 801 private static final class EchoFileDescriptorSupplier 802 extends EchoBaseDescriptorSupplier { EchoFileDescriptorSupplier()803 EchoFileDescriptorSupplier() {} 804 } 805 806 private static final class EchoMethodDescriptorSupplier 807 extends EchoBaseDescriptorSupplier 808 implements io.grpc.protobuf.ProtoMethodDescriptorSupplier { 809 private final String methodName; 810 EchoMethodDescriptorSupplier(String methodName)811 EchoMethodDescriptorSupplier(String methodName) { 812 this.methodName = methodName; 813 } 814 815 @java.lang.Override getMethodDescriptor()816 public com.google.protobuf.Descriptors.MethodDescriptor getMethodDescriptor() { 817 return getServiceDescriptor().findMethodByName(methodName); 818 } 819 } 820 821 private static volatile io.grpc.ServiceDescriptor serviceDescriptor; 822 getServiceDescriptor()823 public static io.grpc.ServiceDescriptor getServiceDescriptor() { 824 io.grpc.ServiceDescriptor result = serviceDescriptor; 825 if (result == null) { 826 synchronized (EchoGrpc.class) { 827 result = serviceDescriptor; 828 if (result == null) { 829 serviceDescriptor = result = io.grpc.ServiceDescriptor.newBuilder(SERVICE_NAME) 830 .setSchemaDescriptor(new EchoFileDescriptorSupplier()) 831 .addMethod(getEchoMethod()) 832 .addMethod(getExpandMethod()) 833 .addMethod(getCollectMethod()) 834 .addMethod(getChatMethod()) 835 .addMethod(getPagedExpandMethod()) 836 .addMethod(getPagedExpandLegacyMethod()) 837 .addMethod(getPagedExpandLegacyMappedMethod()) 838 .addMethod(getWaitMethod()) 839 .addMethod(getBlockMethod()) 840 .build(); 841 } 842 } 843 } 844 return result; 845 } 846 } 847