/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
D | ServerCalls.java | 119 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver = in startCall() local 125 return new UnaryServerCallListener(responseObserver, call); in startCall() 130 private final ServerCallStreamObserverImpl<ReqT, RespT> responseObserver; field in ServerCalls.UnaryServerCallHandler.UnaryServerCallListener 136 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver, in UnaryServerCallListener() argument 139 this.responseObserver = responseObserver; in UnaryServerCallListener() 171 method.invoke(request, responseObserver); in onHalfClose() 172 responseObserver.freeze(); in onHalfClose() 182 responseObserver.cancelled = true; in onCancel() 183 if (responseObserver.onCancelHandler != null) { in onCancel() 184 responseObserver.onCancelHandler.run(); in onCancel() [all …]
|
/external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
D | ChannelzService.java | 67 GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver) { in getTopChannels() argument 71 responseObserver.onNext(ChannelzProtoUtil.toGetTopChannelResponse(rootChannels)); in getTopChannels() 72 responseObserver.onCompleted(); in getTopChannels() 78 GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) { in getChannel() argument 81 responseObserver.onError(Status.NOT_FOUND.asRuntimeException()); in getChannel() 85 responseObserver.onNext( in getChannel() 90 responseObserver.onCompleted(); in getChannel() 96 GetServersRequest request, StreamObserver<GetServersResponse> responseObserver) { in getServers() argument 99 responseObserver.onNext(ChannelzProtoUtil.toGetServersResponse(servers)); in getServers() 100 responseObserver.onCompleted(); in getServers() [all …]
|
D | HealthServiceImpl.java | 41 StreamObserver<HealthCheckResponse> responseObserver) { in check() argument 44 responseObserver.onError(new StatusException( in check() 48 responseObserver.onNext(response); in check() 49 responseObserver.onCompleted(); in check()
|
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/driver/ |
D | LoadWorker.java | 127 final StreamObserver<Control.ServerStatus> responseObserver) { in runServer() argument 141 responseObserver.onNext(Control.ServerStatus.newBuilder() in runServer() 146 responseObserver.onNext(Control.ServerStatus.newBuilder() in runServer() 150 responseObserver.onError(Status.ALREADY_EXISTS in runServer() 156 responseObserver.onError(Status.INTERNAL.withCause(t).asException()); in runServer() 179 responseObserver.onCompleted(); in runServer() 187 final StreamObserver<Control.ClientStatus> responseObserver) { 196 responseObserver.onNext(Control.ClientStatus.newBuilder().build()); 198 responseObserver.onNext(Control.ClientStatus.newBuilder() 202 responseObserver.onError(Status.ALREADY_EXISTS [all …]
|
/external/grpc-grpc-java/benchmarks/src/main/java/io/grpc/benchmarks/qps/ |
D | AsyncServer.java | 214 StreamObserver<Messages.SimpleResponse> responseObserver) { in unaryCall() argument 215 responseObserver.onNext(Utils.makeResponse(request)); in unaryCall() 216 responseObserver.onCompleted(); in unaryCall() 222 final ServerCallStreamObserver<Messages.SimpleResponse> responseObserver = in streamingCall() local 229 responseObserver.onCompleted(); in streamingCall() 232 responseObserver.onNext(Utils.makeResponse(value)); in streamingCall() 238 responseObserver.onError(t); in streamingCall() 244 responseObserver.onCompleted(); in streamingCall() 251 final StreamObserver<Messages.SimpleResponse> responseObserver) { 258 responseObserver.onCompleted(); [all …]
|
/external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
D | ProtoReflectionServiceTest.java | 182 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileByFilename() local 184 stub.serverReflectionInfo(responseObserver); in fileByFilename() 188 assertEquals(goldenResponse, responseObserver.firstValue().get()); in fileByFilename() 209 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileByFilenameConsistentForMutableServices() local 211 stub.serverReflectionInfo(responseObserver); in fileByFilenameConsistentForMutableServices() 229 responseObserver.firstValue().get().getMessageResponseCase()); in fileByFilenameConsistentForMutableServices() 251 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingSymbol() local 253 stub.serverReflectionInfo(responseObserver); in fileContainingSymbol() 258 responseObserver in fileContainingSymbol() 286 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingNestedSymbol() local [all …]
|
/external/grpc-grpc-java/examples/src/test/java/io/grpc/examples/routeguide/ |
D | RouteGuideClientTest.java | 120 public void getFeature(Point point, StreamObserver<Feature> responseObserver) { in getFeature() 122 responseObserver.onNext(responseFeature); in getFeature() 123 responseObserver.onCompleted(); in getFeature() 148 public void getFeature(Point point, StreamObserver<Feature> responseObserver) { in getFeature_error() 150 responseObserver.onError(fakeError); in getFeature_error() 176 public void listFeatures(Rectangle rectangle, StreamObserver<Feature> responseObserver) { in listFeatures() 180 responseObserver.onNext(responseFeature1); in listFeatures() 181 responseObserver.onNext(responseFeature2); in listFeatures() 184 responseObserver.onCompleted(); in listFeatures() 215 public void listFeatures(Rectangle rectangle, StreamObserver<Feature> responseObserver) { in listFeatures_error() [all …]
|
D | RouteGuideServerTest.java | 138 StreamObserver<Feature> responseObserver = in listFeatures() local 158 stub.listFeatures(rect, responseObserver); in listFeatures() 181 StreamObserver<RouteSummary> responseObserver = in recordRoute() local 186 StreamObserver<Point> requestObserver = stub.recordRoute(responseObserver); in recordRoute() 193 verify(responseObserver, never()).onNext(any(RouteSummary.class)); in recordRoute() 198 verify(responseObserver, timeout(100)).onNext(routeSummaryCaptor.capture()); in recordRoute() 202 verify(responseObserver, timeout(100)).onCompleted(); in recordRoute() 203 verify(responseObserver, never()).onError(any(Throwable.class)); in recordRoute() 219 StreamObserver<RouteNote> responseObserver = in routeChat() local 223 StreamObserver<RouteNote> requestObserver = stub.routeChat(responseObserver); in routeChat() [all …]
|
/external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
D | MoreInProcessTest.java | 83 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverResponsePriorToRequest() 85 responseObserver.onNext(fakeResponse); in asyncClientStreaming_serverResponsePriorToRequest() 86 responseObserver.onCompleted(); in asyncClientStreaming_serverResponsePriorToRequest() 108 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverResponsePriorToRequest() local 128 TestServiceGrpc.newStub(inProcessChannel).streamingInputCall(responseObserver); in asyncClientStreaming_serverResponsePriorToRequest() 142 StreamObserver<StreamingInputCallResponse> responseObserver) { in asyncClientStreaming_serverErrorPriorToRequest() 144 responseObserver.onError(new StatusRuntimeException(fakeError)); in asyncClientStreaming_serverErrorPriorToRequest() 145 responseObserver.onCompleted(); in asyncClientStreaming_serverErrorPriorToRequest() 167 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverErrorPriorToRequest() local 187 TestServiceGrpc.newStub(inProcessChannel).streamingInputCall(responseObserver); in asyncClientStreaming_serverErrorPriorToRequest() [all …]
|
/external/flatbuffers/grpc/tests/ |
D | JavaGrpcTest.java | 54 public void store(Monster request, io.grpc.stub.StreamObserver<Stat> responseObserver) { in store() argument 61 responseObserver.onNext(stat); in store() 62 responseObserver.onCompleted(); in store() 66 public void retrieve(Stat request, io.grpc.stub.StreamObserver<Monster> responseObserver) { in retrieve() argument 70 responseObserver.onNext(monster); in retrieve() 72 responseObserver.onCompleted(); in retrieve() 76 public StreamObserver<Monster> getMaxHitPoint(final StreamObserver<Stat> responseObserver) { in getMaxHitPoint() argument 77 return computeMinMax(responseObserver, false); in getMaxHitPoint() 81 … public StreamObserver<Monster> getMinMaxHitPoints(final StreamObserver<Stat> responseObserver) { in getMinMaxHitPoints() argument 82 return computeMinMax(responseObserver, true); in getMinMaxHitPoints() [all …]
|
/external/flatbuffers/tests/MyGame/Example/ |
D | MonsterStorageGrpc.java | 227 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store() argument 228 asyncUnimplementedUnaryCall(getStoreMethod(), responseObserver); in store() local 234 io.grpc.stub.StreamObserver<MyGame.Example.Monster> responseObserver) { in retrieve() argument 235 asyncUnimplementedUnaryCall(getRetrieveMethod(), responseObserver); in retrieve() local 241 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMaxHitPoint() argument 242 return asyncUnimplementedStreamingCall(getGetMaxHitPointMethod(), responseObserver); in getMaxHitPoint() 248 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMinMaxHitPoints() argument 249 return asyncUnimplementedStreamingCall(getGetMinMaxHitPointsMethod(), responseObserver); in getMinMaxHitPoints() 307 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store() argument 309 getChannel().newCall(getStoreMethod(), getCallOptions()), request, responseObserver); in store() local [all …]
|
/external/grpc-grpc-java/interop-testing/src/generated/main/grpc/io/grpc/testing/integration/ |
D | TestServiceGrpc.java | 327 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in emptyCall() argument 328 asyncUnimplementedUnaryCall(getEmptyCallMethod(), responseObserver); in emptyCall() local 337 …o.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver) { in unaryCall() argument 338 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); in unaryCall() local 349 …o.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver) { in cacheableUnaryCall() argument 350 asyncUnimplementedUnaryCall(getCacheableUnaryCallMethod(), responseObserver); in cacheableUnaryCall() local 360 …treamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> responseObserver) { in streamingOutputCall() argument 361 asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), responseObserver); in streamingOutputCall() local 371 …StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse> responseObserver) { in streamingInputCall() argument 372 return asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), responseObserver); in streamingInputCall() [all …]
|
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/routeguide/ |
D | RouteGuideServer.java | 129 public void getFeature(Point request, StreamObserver<Feature> responseObserver) { in getFeature() argument 130 responseObserver.onNext(checkFeature(request)); in getFeature() 131 responseObserver.onCompleted(); in getFeature() 141 public void listFeatures(Rectangle request, StreamObserver<Feature> responseObserver) { in listFeatures() argument 155 responseObserver.onNext(feature); in listFeatures() 158 responseObserver.onCompleted(); in listFeatures() 169 public StreamObserver<Point> recordRoute(final StreamObserver<RouteSummary> responseObserver) { in recordRoute() argument 199 responseObserver.onNext(RouteSummary.newBuilder().setPointCount(pointCount) in recordRoute() 202 responseObserver.onCompleted(); in recordRoute() 215 public StreamObserver<RouteNote> routeChat(final StreamObserver<RouteNote> responseObserver) { in routeChat() argument [all …]
|
/external/grpc-grpc-java/stub/src/test/java/io/grpc/stub/ |
D | ServerCallsTest.java | 95 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in runtimeStreamObserverIsServerCallStreamObserver() 96 assertTrue(responseObserver instanceof ServerCallStreamObserver); in runtimeStreamObserverIsServerCallStreamObserver() 98 (ServerCallStreamObserver<Integer>) responseObserver; in runtimeStreamObserverIsServerCallStreamObserver() 145 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotSetOnCancelHandlerAfterServiceInvocation() 146 callObserver.set((ServerCallStreamObserver<Integer>) responseObserver); in cannotSetOnCancelHandlerAfterServiceInvocation() 173 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotSetOnReadyHandlerAfterServiceInvocation() 174 callObserver.set((ServerCallStreamObserver<Integer>) responseObserver); in cannotSetOnReadyHandlerAfterServiceInvocation() 201 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in cannotDisableAutoFlowControlAfterServiceInvocation() 202 callObserver.set((ServerCallStreamObserver<Integer>) responseObserver); in cannotDisableAutoFlowControlAfterServiceInvocation() 223 public StreamObserver<Integer> invoke(StreamObserver<Integer> responseObserver) { in disablingInboundAutoFlowControlSuppressesRequestsForMoreMessages() [all …]
|
/external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/channelz/v1/ |
D | ChannelzGrpc.java | 264 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetTopChannelsResponse> responseObserver) { in getTopChannels() argument 265 asyncUnimplementedUnaryCall(getGetTopChannelsMethod(), responseObserver); in getTopChannels() local 274 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetServersResponse> responseObserver) { in getServers() argument 275 asyncUnimplementedUnaryCall(getGetServersMethod(), responseObserver); in getServers() local 284 … io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetServerSocketsResponse> responseObserver) { in getServerSockets() argument 285 asyncUnimplementedUnaryCall(getGetServerSocketsMethod(), responseObserver); in getServerSockets() local 294 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetChannelResponse> responseObserver) { in getChannel() argument 295 asyncUnimplementedUnaryCall(getGetChannelMethod(), responseObserver); in getChannel() local 304 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetSubchannelResponse> responseObserver) { in getSubchannel() argument 305 asyncUnimplementedUnaryCall(getGetSubchannelMethod(), responseObserver); in getSubchannel() local [all …]
|
/external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
D | TestServiceImpl.java | 78 StreamObserver<EmptyProtos.Empty> responseObserver) { in emptyCall() argument 79 responseObserver.onNext(EmptyProtos.Empty.getDefaultInstance()); in emptyCall() 80 responseObserver.onCompleted(); in emptyCall() 87 public void unaryCall(SimpleRequest req, StreamObserver<SimpleResponse> responseObserver) { in unaryCall() argument 89 (ServerCallStreamObserver<SimpleResponse>) responseObserver; in unaryCall() 126 responseObserver.onNext(responseBuilder.build()); in unaryCall() 127 responseObserver.onCompleted(); in unaryCall() 136 StreamObserver<StreamingOutputCallResponse> responseObserver) { in streamingOutputCall() argument 138 new ResponseDispatcher(responseObserver).enqueue(toChunkQueue(request)).completeInput(); in streamingOutputCall() 147 final StreamObserver<Messages.StreamingInputCallResponse> responseObserver) { in streamingInputCall() argument [all …]
|
D | Http2Client.java | 228 RstStreamObserver responseObserver = new RstStreamObserver(); in rstAfterData() local 229 asyncStub.unaryCall(simpleRequest, responseObserver); in rstAfterData() 230 if (!responseObserver.awaitCompletion(timeoutSeconds, TimeUnit.SECONDS)) { in rstAfterData() 233 if (responseObserver.getError() == null) { in rstAfterData() 236 assertRstStreamReceived(Status.fromThrowable(responseObserver.getError())); in rstAfterData() 237 if (responseObserver.getResponses().size() != 1) { in rstAfterData() 244 RstStreamObserver responseObserver = new RstStreamObserver(); in rstDuringData() local 245 asyncStub.unaryCall(simpleRequest, responseObserver); in rstDuringData() 246 if (!responseObserver.awaitCompletion(timeoutSeconds, TimeUnit.SECONDS)) { in rstDuringData() 249 if (responseObserver.getError() == null) { in rstDuringData() [all …]
|
/external/grpc-grpc-java/benchmarks/src/generated/main/grpc/io/grpc/benchmarks/proto/ |
D | BenchmarkServiceGrpc.java | 224 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in unaryCall() argument 225 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); in unaryCall() local 236 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingCall() argument 237 return asyncUnimplementedStreamingCall(getStreamingCallMethod(), responseObserver); in streamingCall() 247 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromClient() argument 248 return asyncUnimplementedStreamingCall(getStreamingFromClientMethod(), responseObserver); in streamingFromClient() 258 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromServer() argument 259 asyncUnimplementedUnaryCall(getStreamingFromServerMethod(), responseObserver); in streamingFromServer() local 269 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingBothWays() argument 270 return asyncUnimplementedStreamingCall(getStreamingBothWaysMethod(), responseObserver); in streamingBothWays() [all …]
|
D | WorkerServiceGrpc.java | 196 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer() argument 197 return asyncUnimplementedStreamingCall(getRunServerMethod(), responseObserver); in runServer() 211 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient() argument 212 return asyncUnimplementedStreamingCall(getRunClientMethod(), responseObserver); in runClient() 221 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { in coreCount() argument 222 asyncUnimplementedUnaryCall(getCoreCountMethod(), responseObserver); in coreCount() local 231 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { in quitWorker() argument 232 asyncUnimplementedUnaryCall(getQuitWorkerMethod(), responseObserver); in quitWorker() local 298 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer() argument 300 getChannel().newCall(getRunServerMethod(), getCallOptions()), responseObserver); in runServer() [all …]
|
/external/grpc-grpc-java/testing-proto/src/generated/main/grpc/io/grpc/testing/protobuf/ |
D | SimpleServiceGrpc.java | 197 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in unaryRpc() argument 198 asyncUnimplementedUnaryCall(getUnaryRpcMethod(), responseObserver); in unaryRpc() local 207 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in clientStreamingRpc() argument 208 return asyncUnimplementedStreamingCall(getClientStreamingRpcMethod(), responseObserver); in clientStreamingRpc() 217 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in serverStreamingRpc() argument 218 asyncUnimplementedUnaryCall(getServerStreamingRpcMethod(), responseObserver); in serverStreamingRpc() local 227 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in bidiStreamingRpc() argument 228 return asyncUnimplementedStreamingCall(getBidiStreamingRpcMethod(), responseObserver); in bidiStreamingRpc() 292 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in unaryRpc() argument 294 getChannel().newCall(getUnaryRpcMethod(), getCallOptions()), request, responseObserver); in unaryRpc() local [all …]
|
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/manualflowcontrol/ |
D | ManualFlowControlServer.java | 37 …StreamObserver<HelloRequest> sayHelloStreaming(final StreamObserver<HelloReply> responseObserver) { in main() 41 (ServerCallStreamObserver<HelloReply>) responseObserver; in main() 86 responseObserver.onNext(reply); in main() 104 responseObserver.onError( in main() 113 responseObserver.onCompleted(); in main() 120 responseObserver.onCompleted(); in main()
|
/external/grpc-grpc-java/examples/src/main/java/io/grpc/examples/advanced/ |
D | HelloJsonServer.java | 95 private void sayHello(HelloRequest req, StreamObserver<HelloReply> responseObserver) { in sayHello() argument 97 responseObserver.onNext(reply); in sayHello() 98 responseObserver.onCompleted(); in sayHello() 110 HelloRequest request, StreamObserver<HelloReply> responseObserver) { in bindService() 111 sayHello(request, responseObserver); in bindService()
|
/external/grpc-grpc-java/compiler/src/test/golden/ |
D | TestService.java.txt | 262 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { 263 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); 273 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 274 asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), responseObserver); 284 …c.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { 285 return asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), responseObserver); 296 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 297 return asyncUnimplementedStreamingCall(getFullBidiCallMethod(), responseObserver); 309 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 310 return asyncUnimplementedStreamingCall(getHalfBidiCallMethod(), responseObserver); [all …]
|
/external/grpc-grpc-java/compiler/src/testLite/golden/ |
D | TestService.java.txt | 256 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.Test.SimpleResponse> responseObserver) { 257 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); 267 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 268 asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), responseObserver); 278 …c.stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingInputCallResponse> responseObserver) { 279 return asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), responseObserver); 290 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 291 return asyncUnimplementedStreamingCall(getFullBidiCallMethod(), responseObserver); 303 ….stub.StreamObserver<io.grpc.testing.compiler.Test.StreamingOutputCallResponse> responseObserver) { 304 return asyncUnimplementedStreamingCall(getHalfBidiCallMethod(), responseObserver); [all …]
|
/external/grpc-grpc-java/compiler/src/testNano/golden/ |
D | TestService.java.txt | 297 … io.grpc.stub.StreamObserver<io.grpc.testing.compiler.nano.Test.SimpleResponse> responseObserver) { 298 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); 308 ….StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) { 309 asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), responseObserver); 319 …b.StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingInputCallResponse> responseObserver) { 320 return asyncUnimplementedStreamingCall(getStreamingInputCallMethod(), responseObserver); 331 ….StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) { 332 return asyncUnimplementedStreamingCall(getFullBidiCallMethod(), responseObserver); 344 ….StreamObserver<io.grpc.testing.compiler.nano.Test.StreamingOutputCallResponse> responseObserver) { 345 return asyncUnimplementedStreamingCall(getHalfBidiCallMethod(), responseObserver); [all …]
|