Home
last modified time | relevance | path

Searched refs:responseObserver (Results 1 – 25 of 61) sorted by relevance

123

/external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/
DServerCalls.java119 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/
DChannelzService.java67 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 …]
DHealthServiceImpl.java41 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/
DLoadWorker.java127 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/
DAsyncServer.java214 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/
DProtoReflectionServiceTest.java182 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/
DRouteGuideClientTest.java120 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 …]
DRouteGuideServerTest.java138 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/
DMoreInProcessTest.java83 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/
DJavaGrpcTest.java54 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/
DMonsterStorageGrpc.java227 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/
DTestServiceGrpc.java327 … 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/
DRouteGuideServer.java129 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/
DServerCallsTest.java95 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/
DChannelzGrpc.java264 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/
DTestServiceImpl.java78 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 …]
DHttp2Client.java228 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/
DBenchmarkServiceGrpc.java224 … 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 …]
DWorkerServiceGrpc.java196 … 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/
DSimpleServiceGrpc.java197 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/
DManualFlowControlServer.java37 …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/
DHelloJsonServer.java95 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/
DTestService.java.txt262 … 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/
DTestService.java.txt256 … 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/
DTestService.java.txt297 … 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 …]

123