| /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()
265 asyncUnimplementedUnaryCall(getGetTopChannelsMethod(), responseObserver); in getTopChannels() local
274 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetServersResponse> responseObserver) { in getServers()
275 asyncUnimplementedUnaryCall(getGetServersMethod(), responseObserver); in getServers() local
284 … io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetServerSocketsResponse> responseObserver) { in getServerSockets()
285 asyncUnimplementedUnaryCall(getGetServerSocketsMethod(), responseObserver); in getServerSockets() local
294 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetChannelResponse> responseObserver) { in getChannel()
295 asyncUnimplementedUnaryCall(getGetChannelMethod(), responseObserver); in getChannel() local
304 io.grpc.stub.StreamObserver<io.grpc.channelz.v1.GetSubchannelResponse> responseObserver) { in getSubchannel()
305 asyncUnimplementedUnaryCall(getGetSubchannelMethod(), responseObserver); in getSubchannel() 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()
328 asyncUnimplementedUnaryCall(getEmptyCallMethod(), responseObserver); in emptyCall() local
337 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver)… in unaryCall()
338 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); in unaryCall() local
349 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.SimpleResponse> responseObserver)… in cacheableUnaryCall()
350 asyncUnimplementedUnaryCall(getCacheableUnaryCallMethod(), responseObserver); in cacheableUnaryCall() local
360 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> resp… in streamingOutputCall()
361 asyncUnimplementedUnaryCall(getStreamingOutputCallMethod(), responseObserver); in streamingOutputCall() local
371 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingInputCallResponse> respo… in streamingInputCall()
383 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.StreamingOutputCallResponse> resp… in fullDuplexCall()
[all …]
|
| D | ReconnectServiceGrpc.java | 130 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in start()
131 asyncUnimplementedUnaryCall(getStartMethod(), responseObserver); in start() local
137 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.ReconnectInfo> responseObserver) { in stop()
138 asyncUnimplementedUnaryCall(getStopMethod(), responseObserver); in stop() local
185 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in start()
187 getChannel().newCall(getStartMethod(), getCallOptions()), request, responseObserver); in start() local
193 …io.grpc.stub.StreamObserver<io.grpc.testing.integration.Messages.ReconnectInfo> responseObserver) { in stop()
195 getChannel().newCall(getStopMethod(), getCallOptions()), request, responseObserver); in stop() local
291 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
309 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| D | MetricsServiceGrpc.java | 128 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.Metrics.GaugeResponse> responseObserver) { in getAllGauges()
129 asyncUnimplementedUnaryCall(getGetAllGaugesMethod(), responseObserver); in getAllGauges() local
138 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.Metrics.GaugeResponse> responseObserver) { in getGauge()
139 asyncUnimplementedUnaryCall(getGetGaugeMethod(), responseObserver); in getGauge() local
187 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.Metrics.GaugeResponse> responseObserver) { in getAllGauges()
189 … getChannel().newCall(getGetAllGaugesMethod(), getCallOptions()), request, responseObserver); in getAllGauges() local
198 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.Metrics.GaugeResponse> responseObserver) { in getGauge()
200 getChannel().newCall(getGetGaugeMethod(), getCallOptions()), request, responseObserver); in getGauge() local
293 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
311 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| D | UnimplementedServiceGrpc.java | 103 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in unimplementedCall()
104 asyncUnimplementedUnaryCall(getUnimplementedCallMethod(), responseObserver); in unimplementedCall() local
148 … io.grpc.stub.StreamObserver<io.grpc.testing.integration.EmptyProtos.Empty> responseObserver) { in unimplementedCall()
150 … getChannel().newCall(getUnimplementedCallMethod(), getCallOptions()), request, responseObserver); in unimplementedCall() local
238 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
252 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| /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()
225 asyncUnimplementedUnaryCall(getUnaryCallMethod(), responseObserver); in unaryCall() local
236 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingCall()
247 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromClient()
258 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingFromServer()
259 asyncUnimplementedUnaryCall(getStreamingFromServerMethod(), responseObserver); in streamingFromServer() local
269 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingBothWays()
339 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in unaryCall()
341 getChannel().newCall(getUnaryCallMethod(), getCallOptions()), request, responseObserver); in unaryCall() local
352 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Messages.SimpleResponse> responseObserver) { in streamingCall()
[all …]
|
| D | WorkerServiceGrpc.java | 196 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer()
211 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
221 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { in coreCount()
222 asyncUnimplementedUnaryCall(getCoreCountMethod(), responseObserver); in coreCount() local
231 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { in quitWorker()
232 asyncUnimplementedUnaryCall(getQuitWorkerMethod(), responseObserver); in quitWorker() local
298 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ServerStatus> responseObserver) { in runServer()
314 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.ClientStatus> responseObserver) { in runClient()
325 … io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.CoreResponse> responseObserver) { in coreCount()
327 getChannel().newCall(getCoreCountMethod(), getCallOptions()), request, responseObserver); in coreCount() local
[all …]
|
| D | ReportQpsScenarioServiceGrpc.java | 95 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { in reportScenario()
96 asyncUnimplementedUnaryCall(getReportScenarioMethod(), responseObserver); in reportScenario() local
136 io.grpc.stub.StreamObserver<io.grpc.benchmarks.proto.Control.Void> responseObserver) { in reportScenario()
138 … getChannel().newCall(getReportScenarioMethod(), getCallOptions()), request, responseObserver); in reportScenario() local
218 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
232 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| /external/flatbuffers/tests/MyGame/Example/ |
| D | MonsterStorageGrpc.java | 227 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store()
228 asyncUnimplementedUnaryCall(getStoreMethod(), responseObserver); in store() local
234 io.grpc.stub.StreamObserver<MyGame.Example.Monster> responseObserver) { in retrieve()
235 asyncUnimplementedUnaryCall(getRetrieveMethod(), responseObserver); in retrieve() local
241 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMaxHitPoint()
248 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in getMinMaxHitPoints()
307 io.grpc.stub.StreamObserver<MyGame.Example.Stat> responseObserver) { in store()
309 getChannel().newCall(getStoreMethod(), getCallOptions()), request, responseObserver); in store() local
315 io.grpc.stub.StreamObserver<MyGame.Example.Monster> responseObserver) { in retrieve()
317 getChannel().newCall(getRetrieveMethod(), getCallOptions()), request, responseObserver); in retrieve() local
[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()
198 asyncUnimplementedUnaryCall(getUnaryRpcMethod(), responseObserver); in unaryRpc() local
207 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in clientStreamingRpc()
217 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in serverStreamingRpc()
218 asyncUnimplementedUnaryCall(getServerStreamingRpcMethod(), responseObserver); in serverStreamingRpc() local
227 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in bidiStreamingRpc()
292 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in unaryRpc()
294 getChannel().newCall(getUnaryRpcMethod(), getCallOptions()), request, responseObserver); in unaryRpc() local
303 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in clientStreamingRpc()
314 io.grpc.stub.StreamObserver<io.grpc.testing.protobuf.SimpleResponse> responseObserver) { in serverStreamingRpc()
[all …]
|
| /external/grpc-grpc-java/services/src/main/java/io/grpc/services/ |
| D | ChannelzService.java | 67 GetTopChannelsRequest request, StreamObserver<GetTopChannelsResponse> responseObserver) { in getTopChannels()
78 GetChannelRequest request, StreamObserver<GetChannelResponse> responseObserver) { in getChannel()
96 GetServersRequest request, StreamObserver<GetServersResponse> responseObserver) { in getServers()
106 GetSubchannelRequest request, StreamObserver<GetSubchannelResponse> responseObserver) { in getSubchannel()
124 GetSocketRequest request, StreamObserver<GetSocketResponse> responseObserver) { in getSocket()
141 GetServerSocketsRequest request, StreamObserver<GetServerSocketsResponse> responseObserver) { in getServerSockets()
|
| /external/grpc-grpc-java/services/src/test/java/io/grpc/protobuf/services/ |
| D | ProtoReflectionServiceTest.java | 182 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileByFilename() local
209 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileByFilenameConsistentForMutableServices() local
251 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingSymbol() local
286 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingNestedSymbol() local
312 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingSymbolForMutableServices() local
358 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingExtension() local
399 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingNestedExtension() local
429 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in fileContainingExtensionForMutableServices() local
466 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in allExtensionNumbersOfType() local
500 StreamRecorder<ServerReflectionResponse> responseObserver = StreamRecorder.create(); in allExtensionNumbersOfTypeForMutableServices() local
[all …]
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/health/v1/ |
| D | HealthGrpc.java | 128 io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) { in check()
129 asyncUnimplementedUnaryCall(getCheckMethod(), responseObserver); in check() local
150 io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) { in watch()
151 asyncUnimplementedUnaryCall(getWatchMethod(), responseObserver); in watch() local
199 io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) { in check()
201 getChannel().newCall(getCheckMethod(), getCallOptions()), request, responseObserver); in check() local
222 io.grpc.stub.StreamObserver<io.grpc.health.v1.HealthCheckResponse> responseObserver) { in watch()
224 getChannel().newCall(getWatchMethod(), getCallOptions()), request, responseObserver); in watch() local
330 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
348 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| /external/grpc-grpc-java/interop-testing/src/main/java/io/grpc/testing/integration/ |
| D | TestServiceImpl.java | 78 StreamObserver<EmptyProtos.Empty> responseObserver) { in emptyCall()
87 public void unaryCall(SimpleRequest req, StreamObserver<SimpleResponse> responseObserver) { in unaryCall()
136 StreamObserver<StreamingOutputCallResponse> responseObserver) { in streamingOutputCall()
147 final StreamObserver<Messages.StreamingInputCallResponse> responseObserver) { in streamingInputCall()
176 final StreamObserver<Messages.StreamingOutputCallResponse> responseObserver) { in fullDuplexCall()
|
| /external/dagger2/javatests/dagger/grpc/functional/server/ |
| D | FriendlyBarista.java | 39 CoffeeRequest request, StreamObserver<CoffeeResponse> responseObserver) { in unaryGetCoffee()
46 final StreamObserver<CoffeeResponse> responseObserver) { in clientStreamingGetCoffee()
70 CoffeeRequest request, StreamObserver<CoffeeResponse> responseObserver) { in serverStreamingGetCoffee()
79 final StreamObserver<CoffeeResponse> responseObserver) { in bidiStreamingGetCoffee()
|
| D | BaristaTest.java | 91 private final CoffeeResponseObserver responseObserver = new CoffeeResponseObserver(); field in BaristaTest
107 barista.unaryGetCoffee(request(POUR_OVER, LATTE), responseObserver); in testUnaryGetCoffee() local
126 barista.serverStreamingGetCoffee(request(DRIP, AMERICANO), responseObserver); in testServerStreamingGetCoffee() local
|
| /external/flatbuffers/grpc/tests/ |
| D | JavaGrpcTest.java | 54 public void store(Monster request, io.grpc.stub.StreamObserver<Stat> responseObserver) { in store()
66 public void retrieve(Stat request, io.grpc.stub.StreamObserver<Monster> responseObserver) { in retrieve()
76 public StreamObserver<Monster> getMaxHitPoint(final StreamObserver<Stat> responseObserver) { in getMaxHitPoint()
81 … public StreamObserver<Monster> getMinMaxHitPoints(final StreamObserver<Stat> responseObserver) { in getMinMaxHitPoints()
85 …private StreamObserver<Monster> computeMinMax(final StreamObserver<Stat> responseObserver, final b… in computeMinMax()
|
| /external/grpc-grpc-java/stub/src/main/java/io/grpc/stub/ |
| D | ServerCalls.java | 119 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver = in startCall() local
130 private final ServerCallStreamObserverImpl<ReqT, RespT> responseObserver; field in ServerCalls.UnaryServerCallHandler.UnaryServerCallListener
136 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver, in UnaryServerCallListener()
219 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver = in startCall() local
232 private final ServerCallStreamObserverImpl<ReqT, RespT> responseObserver; field in ServerCalls.StreamingServerCallHandler.StreamingServerCallListener
239 ServerCallStreamObserverImpl<ReqT, RespT> responseObserver, in StreamingServerCallListener()
296 void invoke(ReqT request, StreamObserver<RespT> responseObserver); in invoke()
300 StreamObserver<ReqT> invoke(StreamObserver<RespT> responseObserver); in invoke()
403 MethodDescriptor<?, ?> methodDescriptor, StreamObserver<?> responseObserver) { in asyncUnimplementedUnaryCall()
419 MethodDescriptor<?, ?> methodDescriptor, StreamObserver<?> responseObserver) { in asyncUnimplementedStreamingCall()
|
| /external/grpc-grpc-java/services/src/generated/test/grpc/io/grpc/reflection/testing/ |
| D | DynamicServiceGrpc.java | 101 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.DynamicReply> responseObserver) { in method()
102 asyncUnimplementedUnaryCall(getMethodMethod(), responseObserver); in method() local
145 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.DynamicReply> responseObserver) { in method()
147 getChannel().newCall(getMethodMethod(), getCallOptions()), request, responseObserver); in method() local
233 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
247 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| D | AnotherDynamicServiceGrpc.java | 101 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.DynamicReply> responseObserver) { in method()
102 asyncUnimplementedUnaryCall(getMethodMethod(), responseObserver); in method() local
145 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.DynamicReply> responseObserver) { in method()
147 getChannel().newCall(getMethodMethod(), getCallOptions()), request, responseObserver); in method() local
233 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
247 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| D | ReflectableServiceGrpc.java | 92 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.Reply> responseObserver) { in method()
93 asyncUnimplementedUnaryCall(getMethodMethod(), responseObserver); in method() local
130 io.grpc.stub.StreamObserver<io.grpc.reflection.testing.Reply> responseObserver) { in method()
132 getChannel().newCall(getMethodMethod(), getCallOptions()), request, responseObserver); in method() local
206 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
220 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| /external/grpc-grpc-java/interop-testing/src/test/java/io/grpc/testing/integration/ |
| D | MoreInProcessTest.java | 108 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverResponsePriorToRequest() local
167 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_serverErrorPriorToRequest() local
226 StreamObserver<StreamingInputCallResponse> responseObserver = in asyncClientStreaming_erroneousServiceImpl() local
|
| /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()
141 public void listFeatures(Rectangle request, StreamObserver<Feature> responseObserver) { in listFeatures()
169 public StreamObserver<Point> recordRoute(final StreamObserver<RouteSummary> responseObserver) { in recordRoute()
215 public StreamObserver<RouteNote> routeChat(final StreamObserver<RouteNote> responseObserver) { in routeChat()
|
| /external/grpc-grpc-java/services/src/generated/main/grpc/io/grpc/reflection/v1alpha/ |
| D | ServerReflectionGrpc.java | 96 …io.grpc.stub.StreamObserver<io.grpc.reflection.v1alpha.ServerReflectionResponse> responseObserver)… in serverReflectionInfo()
138 …io.grpc.stub.StreamObserver<io.grpc.reflection.v1alpha.ServerReflectionResponse> responseObserver)… in serverReflectionInfo()
199 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
209 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|
| /external/grpc-grpc-java/alts/src/generated/main/grpc/io/grpc/alts/internal/ |
| D | HandshakerServiceGrpc.java | 100 … io.grpc.stub.StreamObserver<io.grpc.alts.internal.Handshaker.HandshakerResp> responseObserver) { in doHandshake()
146 … io.grpc.stub.StreamObserver<io.grpc.alts.internal.Handshaker.HandshakerResp> responseObserver) { in doHandshake()
207 public void invoke(Req request, io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
217 io.grpc.stub.StreamObserver<Resp> responseObserver) { in invoke()
|